EventMachineはチャンク内のファイルを読み書きします

Question

私はEventMachineとEM-SynchronyをREST APIサーバーで使用しています。本体の大きなバイナリファイルを持つPOSTリクエストを受信すると、チャンクで受信し、そのチャンクをTempfileに書き込み、リアクタはブロックしません。

その後、ある時点で、このファイルをチャンクで読み込み、そのチャンクを最終的なファイルに書き込む必要があります。これは機能していますが、期待通りに原子炉をブロックし、ブロックせずに原子炉を動作させる方法を見つけることはできません。

私はそれに一時ファイルと新しいファイル名を渡して、いくつかの時点で、この関数を呼び出す：

def self.save(tmp_file, new_file) 
    tmp = File.open(tmp_file, "rb") 
    newf = File.open(new_file, "wb") 
    md5 = Digest::MD5.new 

    each_chunk(tmp, CHUNKSIZE) do |chunk| 
    newf << chunk 
    md5.update chunk 
    end 

    md5.hexdigest 
end 

def self.each_chunk(file, chunk_size=1024) 
    yield file.read(chunk_size) until file.eof? 
end 

私はEM番号のnext_tickを使用しようと、StackOverflowのでここにすべての他の同様の質問を読んでいます、おそらく解決策（それほど多くのEM経験ではありませんが）はうまくいきません。おそらく私は間違った場所に配置しています。

また、EM＃deferを試しましたが、この関数を呼び出してからデータベースの更新を行うと、メインファイルのようにmd5を返す前に読み取り/書き込み処理が完了するまで待つ関数が必要です戻り値を返します。

誰かが私にこれを助けることができたら、私は感謝します。

def copy_and_update(...) 
    checksum = SomeModule.save(temp_file, new_file) 
    do_database_update({:checksum => checksum}) # only with the final md5 value 
end 

：私は機能を保存するだけで、後の私は、最終的なMD5値を待っている呼び出し元の関数のように、ファイルは、読み取り/書き込み完了このような何かを返すことを必要

EDIT 1

Answer 1

は、あなたはそれを破るためにそこに何かを注入する必要があります。

def self.each_chunk(file, chunk_size=1024) 
    chunk_handler = lambda { 
    unless (file.eof?) 
     yield file.read(chunk_size) 


    EM.next_tick(&chunk_handler) 
    end 
    } 

    EM.next_tick(&chunk_handler) 
end 

それはこのようにそれを行うには一種の厄介だが、そのような非同期プログラミングです。