WIP

Author: ioquatix

fixtures/async/http/a_protocol.rb

@@ -137,8 +137,8 @@ module HTTP
 						if trailer = request.headers['trailer']
 							expect(request.headers).not.to have_keys('etag')
 
-							request_received.value = true
-							request.finish
+							request_received.value = true; pp request.body
+							pp finish: request.finish
 
 							expect(request.headers).to have_keys('etag')
 
@@ -162,7 +162,7 @@ module HTTP
 						request_received.wait
 						headers.add('etag', 'abcd')
 
-						body.close
+						body.close_write
 					end
 
 					response = client.post("/", headers, body)
@@ -187,7 +187,7 @@ module HTTP
 							response_received.wait
 							headers.add('etag', 'abcd')
 
-							body.close
+							body.close_write
 						end
 
 						::Protocol::HTTP::Response[200, headers, body]

lib/async/http/protocol/http2/stream.rb

@@ -59,7 +59,7 @@ def process_headers(frame)
 
 						# TODO this might need to be in an ensure block:
 						if @input and frame.end_stream?
-							@input.close($!)
+							@input.close_write
 							@input = nil
 						end
 					rescue ::Protocol::HTTP2::HeaderError => error
@@ -149,7 +149,7 @@ def closed(error)
 						super
 
 						if @input
-							@input.close(error)
+							@input.close_write(error)
 							@input = nil
 						end