Fix tests.

lib/protocol/http/body/streamable.rb

@@ -17,6 +17,14 @@ module Body
 			#
 			# When invoking `call(stream)`, the stream can be read from and written to, and closed. However, the stream is only guaranteed to be open for the duration of the `call(stream)` call. Once the method returns, the stream **should** be closed by the server.
 			module Streamable
+				def self.new(*arguments)
+					if arguments.size == 1
+						RequestBody.new(*arguments)
+					else
+						ResponseBody.new(*arguments)
+					end
+				end
+
 				# Represents an output wrapper around a stream, that can invoke a fiber when `#read`` is called.
 				#
 				# This behaves a little bit like a generator or lazy enumerator, in that it can be used to generate chunks of data on demand.

test/protocol/http/body/streamable.rb

@@ -14,8 +14,7 @@
 		end
 	end
 
-	let(:input) {nil}
-	let(:body) {subject.new(block, input)}
+	let(:body) {subject.new(block)}
 
 	with "#stream?" do
 		it "should be streamable" do
@@ -75,7 +74,7 @@
 			end
 		end
 
-		let(:body) {subject.new(block, input)}
+		let(:body) {subject.new(block)}
 
 		it "can close the output body" do
 			expect(body.read).to be == nil
@@ -118,7 +117,7 @@
 
 				expect(stream.string).to be == "Hello"
 
-				body.stream(input)
+				body.stream(nil)
 			end
 		end
 	end
@@ -155,6 +154,8 @@
 			end
 		end
 
+		let(:body) {subject.new(block, input)}
+
 		it "can read from input" do
 			expect(body.read).to be == "Hello"
 			expect(body.read).to be == " "