class Protocol::Rack::Body::Streaming

Wraps a streaming response body into a compatible Protocol::HTTP body.

def call(stream)
	@block.call(stream)
end

def each(&block)
	stream = ::Protocol::HTTP::Body::Stream.new(@input, Output.new(block))
	
	@block.call(stream)
end

def initialize(block, input = nil)
	@block = block
	@input = input
end

def stream?
	true
end