class Async::HTTP::Body::Streamable

def self.wrap(message, &block)
	if message and message.body
		if remaining = message.headers['content-length']
			remaining = Integer(remaining)
		end
		
		message.body = self.new(message.body, block, remaining)
	else
		yield
	end
end