async sinatra를 사용하여 스트림 다중 본문

Question

자바 스크립트에서 긴 폴링 요청을 시작하고 자바 스크립트에 여러 본문 섹션을 스트리밍하도록 루비 프로그램을 기대합니다. 왜 다음 (pseudo) 코드가 작동하지 않습니까?

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 

아마 내가 오래 무엇 폴링 및 비동기 수행하도록되어 오해하지만 내 기대는 내가 클라이언트로 다시 전송 여러 기관을 얻을 수 있다는 것입니다? 이벤트 머신 등을 사용해야합니까? 그것은 그 아래 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

당신은 여러 기관의 전송을 트리거하는 EventMachine 이벤트가 필요합니다. 이 이전의 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