Update tests.

Author: ioquatix

test/async/http/protocol/streaming.rb renamed to test/protocol/http/body/stream.rb

@@ -130,8 +130,8 @@
 	end
 end
 
-[Async::HTTP::Protocol::HTTP1].each do |protocol|
-	describe protocol do
+[Async::HTTP::Protocol::HTTP1, Async::HTTP::Protocol::HTTP2].each do |protocol|
+	describe protocol, unique: protocol.name do
 		include Sus::Fixtures::Async::HTTP::ServerContext
 
 		let(:protocol) {subject}

test/async/http/protocol/closable.rb renamed to test/protocol/http/body/streamable.rb

@@ -10,55 +10,56 @@
 AnEchoServer = Sus::Shared("an echo server") do
 	let(:app) do
 		::Protocol::HTTP::Middleware.for do |request|
-			body = ::Protocol::HTTP::Body::Streamable.response(request) do |stream|
-				# $stderr.puts "Server stream: #{stream.inspect}"
-				
+			streamable = ::Protocol::HTTP::Body::Streamable.response(request) do |stream|
+				Console.debug(self, "Echoing chunks...")
 				while chunk = stream.readpartial(1024)
-					# $stderr.puts "Server reading chunk: #{chunk.inspect}"
+					Console.debug(self, "Reading chunk:", chunk: chunk)
 					stream.write(chunk)
 				end
 			rescue EOFError
+				Console.debug(self, "EOF.")
 				# Ignore.
 			ensure
-				# $stderr.puts "Server closing stream."
+				Console.debug(self, "Closing stream.")
 				stream.close
 			end
 
-			::Protocol::HTTP::Response[200, {}, body]
+			::Protocol::HTTP::Response[200, {}, streamable]
 		end
 	end
 
 	it "should echo the request body" do
 		chunks = ["Hello,", "World!"]
 		response_chunks = Queue.new
 
-		body = ::Protocol::HTTP::Body::Streamable.request do |stream|
-			# $stderr.puts "Client stream: #{stream.inspect}"
-			
+		output = ::Protocol::HTTP::Body::Writable.new
+		response = client.post("/", body: output)
+		stream = ::Protocol::HTTP::Body::Stream.new(response.body, output)
+		
+		begin
+			Console.debug(self, "Echoing chunks...")
 			chunks.each do |chunk|
-				# $stderr.puts "Client writing chunk: #{chunk.inspect}"
+				Console.debug(self, "Writing chunk:", chunk: chunk)
 				stream.write(chunk)
 			end
 
-			# $stderr.puts "Client closing write."
+			Console.debug(self, "Closing write.")
 			stream.close_write
 
-			# $stderr.puts "Client reading chunks..."
+			Console.debug(self, "Reading chunks...")
 			while chunk = stream.readpartial(1024)
-				# $stderr.puts "Client reading chunk: #{chunk.inspect}"
+				Console.debug(self, "Reading chunk:", chunk: chunk)
 				response_chunks << chunk
 			end
 		rescue EOFError
+			Console.debug(self, "EOF.")
 			# Ignore.
 		ensure
-			# $stderr.puts "Client closing stream."
+			Console.debug(self, "Closing stream.")
 			stream.close
 			response_chunks.close
 		end
 
-		response = client.post("/", body: body)
-		body.stream(response.body)
-		
 		chunks.each do |chunk|
 			expect(response_chunks.pop).to be == chunk
 		end
@@ -71,54 +72,63 @@
 
 	let(:app) do
 		::Protocol::HTTP::Middleware.for do |request|
-			body = ::Protocol::HTTP::Body::Streamable.response(request) do |stream|
+			streamable = ::Protocol::HTTP::Body::Streamable.response(request) do |stream|
+				Console.debug(self, "Echoing chunks...")
 				chunks.each do |chunk|
 					stream.write(chunk)
 				end
 
+				Console.debug(self, "Closing write.")
 				stream.close_write
 
+				Console.debug(self, "Reading chunks...")
 				while chunk = stream.readpartial(1024)
+					Console.debug(self, "Reading chunk:", chunk: chunk)
 					response_chunks << chunk
 				end
 			rescue EOFError
+				Console.debug(self, "EOF.")
 				# Ignore.
 			ensure
-				# $stderr.puts "Server closing stream."
+				Console.debug(self, "Closing stream.")
 				stream.close
 			end
 
-			::Protocol::HTTP::Response[200, {}, body]
+			::Protocol::HTTP::Response[200, {}, streamable]
 		end
 	end
 
 	it "should echo the response body" do
-		body = ::Protocol::HTTP::Body::Streamable.request do |stream|
+		output = ::Protocol::HTTP::Body::Writable.new
+		response = client.post("/", body: output)
+		stream = ::Protocol::HTTP::Body::Stream.new(response.body, output)
+		
+		begin
+			Console.debug(self, "Echoing chunks...")
 			while chunk = stream.readpartial(1024)
 				stream.write(chunk)
 			end
 		rescue EOFError
+			Console.debug(self, "EOF.")
 			# Ignore.
 		ensure
+			Console.debug(self, "Closing stream.")
 			stream.close
 		end
 
-		response = client.post("/", body: body)
-		body.stream(response.body)
-		
 		chunks.each do |chunk|
 			expect(response_chunks.pop).to be == chunk
 		end
 	end
 end
 
-[Async::HTTP::Protocol::HTTP1].each do |protocol|
-	describe protocol do
+[Async::HTTP::Protocol::HTTP1, Async::HTTP::Protocol::HTTP2].each do |protocol|
+	describe protocol, unique: protocol.name do
 		include Sus::Fixtures::Async::HTTP::ServerContext
 
 		let(:protocol) {subject}
 
 		it_behaves_like AnEchoServer
-		# it_behaves_like AnEchoClient
+		it_behaves_like AnEchoClient
 	end
 end