lib/async/io/ssl_socket.rb in async-io-1.30.2 vs lib/async/io/ssl_socket.rb in async-io-1.31.0
- old
+ new
@@ -66,20 +66,18 @@
def initialize(socket, context)
if socket.is_a?(self.class.wrapped_klass)
super
else
io = self.class.wrapped_klass.new(socket.to_io, context)
+ super(io, socket.reactor)
# We detach the socket from the reactor, otherwise it's possible to add the file descriptor to the selector twice, which is bad.
socket.reactor = nil
# This ensures that when the internal IO is closed, it also closes the internal socket:
io.sync_close = true
- # Copy the timeout:
@timeout = socket.timeout
-
- super(io, socket.reactor)
end
end
def local_address
@io.to_io.local_address