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

Question

我正在努力让服务器发送的事件在 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 应用程序，但我不知道如何使用流插件来实现相同的效果。