class Sinatra::Helpers::Stream

def initialize(scheduler = self.class, keep_open = false, &back)

def initialize(scheduler = self.class, keep_open = false, &back)
  @back, @scheduler, @keep_open = back.to_proc, scheduler, keep_open
  @callbacks, @closed = [], false
end