class Roda::RodaPlugins::Streaming::Stream

def initialize(opts=OPTS, &back)
  @scheduler = opts[:scheduler] || Scheduler.new(self)
  @back = back.to_proc
  @keep_open = opts[:keep_open]
  @callbacks = []
  @closed = false
  if opts[:callback]
    callback(&opts[:callback])
  end
end