The options need to be passed through to the address endpoints.

lib/async/io/peer.rb

@@ -18,6 +18,9 @@ def connected?
 				# If we can wait for the socket to become readable, we know that the socket may still be open.
 				result = to_io.recv_nonblock(1, MSG_PEEK, exception: false)
 
+				# No data was available - newer Ruby can return nil instead of empty string:
+				return false if result.nil?
+
 				# Either there was some data available, or we can wait to see if there is data avaialble.
 				return !result.empty? || result == :wait_readable
 

lib/async/io/shared_endpoint.rb

@@ -50,10 +50,11 @@ def initialize(endpoint, wrappers, **options)
 
 			def local_address_endpoint(**options)
 				endpoints = @wrappers.map do |wrapper|
-					AddressEndpoint.new(wrapper.to_io.local_address)
+					# Forward the options to the internal endpoints:
+					AddressEndpoint.new(wrapper.to_io.local_address, **options)
 				end
 
-				return CompositeEndpoint.new(endpoints, **options)
+				return CompositeEndpoint.new(endpoints)
 			end
 
 			def remote_address_endpoint(**options)