Ensure socket is open before calling readable?.

socketry · Apr 20, 2024 · ad1bd35 · ad1bd35
1 parent ca71154
commit ad1bd35
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/lib/async/http/protocol/http1/connection.rb b/lib/async/http/protocol/http1/connection.rb
@@ -52,7 +52,7 @@ def concurrency
 
 					# Can we use this connection to make requests?
 					def viable?
-						@ready && @stream&.readable?
+						@ready && !@stream.closed? && @stream&.readable?
 					end
 
 					def reusable?

diff --git a/lib/async/http/protocol/http1/request.rb b/lib/async/http/protocol/http1/request.rb
@@ -15,7 +15,7 @@ def self.read(connection)
 							self.new(connection, *parts)
 						end
 					end
-
+					
 					UPGRADE = 'upgrade'
 
 					def initialize(connection, authority, method, path, version, headers, body)

diff --git a/lib/async/http/protocol/http2/connection.rb b/lib/async/http/protocol/http2/connection.rb
@@ -129,7 +129,7 @@ def concurrency
 
 					# Can we use this connection to make requests?
 					def viable?
-						@stream.readable?
+						!@stream.closed? && @stream.readable?
 					end
 
 					def reusable?
-Original file line number
+Diff line change
@@ Expand Up / @@ -15,7 +15,7 @@ def self.read(connection) @@
     							self.new(connection, *parts)
     						end
     					end
     					UPGRADE = 'upgrade'
     					def initialize(connection, authority, method, path, version, headers, body)
@@ Expand Down @@