class Async::HTTP::Body::Streamable

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