class Roda::RodaPlugins::Streaming::AsyncStream

def initialize(opts=OPTS, &block)
  @stream = Stream.new(opts, &block)
  @queue = opts[:queue] || SizedQueue.new(10) # have some default backpressure
  @thread = Thread.new { enqueue_chunks }
end