class Async::HTTP::Body::Streamable

def self.wrap(message, &block)
	if message and body = message.body
		if remaining = body.length
			remaining = Integer(remaining)
		end
		
		message.body = self.new(message.body, block, remaining)
	else
		yield
	end
end