class Roda::RodaPlugins::Streaming::AsyncStream

Push each streaming chunk onto the queue.

def enqueue_chunks
  @stream.each do |chunk|
    @queue.push(chunk)
  end
rescue ClosedQueueError
  # connection was closed
ensure
  @queue.close
end