class Roda::RodaPlugins::Streaming::AsyncStream

Continue streaming data until the stream is finished.

def each(&out)
  dequeue_chunks(&out)
  @thread.join
end