class Protocol::Rack::Body::Streaming::Output
def initialize(input, block)
def initialize(input, block) stream = ::Protocol::HTTP::Body::Stream.new(input, self) @fiber = Fiber.new do block.call(stream) @fiber = nil end end
def initialize(input, block) stream = ::Protocol::HTTP::Body::Stream.new(input, self) @fiber = Fiber.new do block.call(stream) @fiber = nil end end