4

私はgemを使用して非同期ルートを実装していますが、この目的async_sinatraの代わりにSinatraのストリーミングAPIを使用できるという投稿をどこかで見つけました。async_sinatraストリーミングを使用して、以下と同じ機能を実装できますか？

require 'em-hiredis'
require 'sinatra/async'

class App < Sinatra::Base
  register Sinatra::Async

  def redis
    @redis ||= EM::Hiredis.connect
  end

  aget '/' do
    redis.blpop('abcdef', 15).
      callback {|x| body "x=#{x}"}.
      errback {|e| body "e=#{e}"}
  end

  run! if app_file == $0
end
4

1 に答える 1

3

私自身の質問に答えるために：

require 'em-hiredis'
require 'sinatra/base'

class App < Sinatra::Base
  def redis
    @redis ||= EM::Hiredis.connect
  end

  get '/' do
    stream :keep_open do |out|
      redis.blpop('abcdef', 15).callback do |x|
        out << "x=#{x}"
        out.close
      end.errback do |e|
        out << "e=#{e}"
        out.close
      end
    end
  end

  run! if app_file == $0
end
于 2013-02-21T05:10:27.323 に答える