class Roda::RodaPlugins::Streaming::AsyncStream

def dequeue_chunks

Pop each streaming chunk from the queue and yield it. 
def dequeue_chunks
  while chunk = @queue.pop
    yield chunk
  end
end