class Roda::RodaPlugins::Streaming::AsyncStream

def close

Stop streaming.
def close
  @queue.close # terminate the producer thread
  @stream.close
end