lib/async/http/protocol/http2/stream.rb in async-http-0.38.0 vs lib/async/http/protocol/http2/stream.rb in async-http-0.38.1

@@ -41,9 +41,15 @@
 					
 					def create_promise_stream(headers, stream_id)
 						@delegate.create_promise_stream(headers, stream_id)
 					end
 					
+					def close!(state = :closed)
+						super
+						
+						@delegate.close!(state)
+					end
+					
 					def send_body(body, task: Async::Task.current)
 						# TODO Might need to stop this task when body is cancelled.
 						@task = task.async do |subtask|
 							subtask.annotate "Sending body: #{body.class}"