class Roda::RodaPlugins::Streaming::Stream::Scheduler

and reraise the exception if so.
Close the stream if there is an exception when scheduling,

def schedule(*)
  yield
rescue Exception
  @stream.close
  raise
end