class Roda::RodaPlugins::Streaming::Stream

any callbacks.
If not already closed, close the connection, and call

def close
  return if closed?
  @closed = true
  @scheduler.schedule{@callbacks.each(&:call)}
end