async sinatraを使用したスト​​リームの複数のボディ

Question

javascriptからの長いポーリングリクエストを開始したいと思います。私はRuby Progが複数のボディセクションをJavascriptにストリームすることを期待しています。なぜ、次の（疑似）コードは機能しませんか？

require 'rubygems' 
require 'sinatra/async' 
require 'eventmachine' 
require 'thin' 
require 'json' 

    class Test < Sinatra:Base 
     register Sinatra::Async 

     aget '/process' do 
     for c in 1..10 
      body { 
      { :data => [ "this is part #{c}" ] }.to_json 
      end 
     end 
     end 

     run! 
    end 

たぶん私は長い間何ポーリングと非同期の誤解を行うことになって、私の期待は、私がクライアントに送り返され、複数の遺体を得るということですか？私はイベントマシンや何かを使う必要がありますか？それはあなたが複数の遺体の送信をトリガーするためにEventMachineイベントを必要とする以下のexampleに表示されます

おかげ

Answer 1

require 'rubygems' 
require 'sinatra/async' 
require 'thin' 
require 'json' 

class Test < Sinatra::Base 
    register Sinatra::Async 

    class JSONStream 
    include EventMachine::Deferrable 

    def stream(object) 
     @block.call object.to_json + "\n" 
    end 

    def each(&block) 
     @block = block 
    end 
    end 

    aget '/process' do 
    puts 'ok' 
    out = JSONStream.new 
    body out 
    EM.next_tick do 
     c = 0 
     timer = EM.add_periodic_timer(0.3) do 
     c += 1 
     out.stream :data => ["this is part #{c}"] 
     if c == 100 
      timer.cancel 
      out.succeed 
     end 
     end 
    end 
    end 

    run! 
end 

も参照してください：http://confreaks.net/videos/564-scotlandruby2011-real-time-rack

Answer 2

。この前のanswerも参照してください。

require 'sinatra/async' 

class AsyncTest < Sinatra::Base 
    register Sinatra::Async 

    aget '/' do 
    body "hello async" 
    end 

    aget '/delay/:n' do |n| 
    EM.add_timer(n.to_i) { body { "delayed for #{n} seconds" } } 
    end 

end