class Roda::RodaPlugins::Streaming::Stream

Class of the response body in case you use #stream.

Add output to the streaming response body. Returns self.

def <<(data)
  write(data)
  self
end

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

def close
  return if closed?
  @closed = true
  @callback.call if @callback
end

Whether the connection has already been closed.

def closed?
  @closed
end

Yield values to the block as they are passed in via #<<.

def each(&out)
  @out = out
  @block.call(self)
ensure
  close
end

Handle streaming options, see Streaming for details.

def initialize(opts=OPTS, &block)
  @block = block
  @out = nil
  @callback = opts[:callback]
  @closed = false
end

Add output to the streaming response body. Returns number of bytes written.

def write(data)
  data = data.to_s
  @out.call(data)
  data.bytesize
end