使用 sinatra 流 API 的异步请求答案

【问题标题】：async requests using sinatra streaming API使用 sinatra 流 API 的异步请求
【发布时间】：2013-02-21 02:02:50
【问题描述】：

我使用async_sinatra gem 来实现异步路由，但我在某处看到一篇帖子说可以使用 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

【问题讨论】：

标签： ruby sinatra eventmachine

【解决方案1】：

回答我自己的问题：

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

【讨论】：