Skip to content
This repository was archived by the owner on Aug 29, 2024. It is now read-only.

Commit 7d5657b

Browse files
committed
May be native IO. Don't try to clear reactor.
1 parent 268c0b5 commit 7d5657b

File tree

1 file changed

+8
-2
lines changed

1 file changed

+8
-2
lines changed

lib/async/io/shared_endpoint.rb

Lines changed: 8 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,10 @@ def self.bound(endpoint, backlog: Socket::SOMAXCONN, close_on_exec: false, **opt
2424
end
2525

2626
server.close_on_exec = close_on_exec
27-
server.reactor = nil
27+
28+
if server.respond_to?(:reactor=)
29+
server.reactor = nil
30+
end
2831
end
2932

3033
return self.new(endpoint, wrappers)
@@ -35,7 +38,10 @@ def self.connected(endpoint, close_on_exec: false)
3538
wrapper = endpoint.connect
3639

3740
wrapper.close_on_exec = close_on_exec
38-
wrapper.reactor = nil
41+
42+
if wrapper.respond_to?(:reactor=)
43+
wrapper.reactor = nil
44+
end
3945

4046
return self.new(endpoint, [wrapper])
4147
end

0 commit comments

Comments
 (0)