如何使用 Roda 获取服务器发送的事件

如何解决如何使用 Roda 获取服务器发送的事件

我正在努力让服务器发送事件在 Roda 中工作。我遇到的最简单的 Sinatra 实现如下：

class App < Sinatra::Base
  set :server,'thin'
  @@connections = []

  get '/' do
    haml :index
  end

  get '/stream',provides: 'text/event-stream' do
    stream :keep_open do |out|
      @@connections << out
      out.callback { @@connections.delete(out) }
    end
  end

  post '/stream' do
    @@connections.each { |out| out << "data: #{params[:msg]}\n\n" }
    204 # response without entity body
  end
end

这是“开箱即用”的，应该很容易转换成类似的 Roda 应用程序，但我不知道如何使用流媒体插件来实现相同的效果。