We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
Endpoint#wrapper
1 parent 8875296 commit 2f96c4fCopy full SHA for 2f96c4f
lib/async/dns/server.rb
@@ -104,13 +104,15 @@ def run
104
Console.info "Starting Async::DNS server (v#{Async::DNS::VERSION})..."
105
106
Async do |task|
107
+ wrapper = @endpoint.wrapper
108
+
109
@endpoint.bind do |server|
110
Console.info "<> Listening for connections on #{server.local_address.inspect}"
111
case server.local_address.socktype
112
when Socket::SOCK_DGRAM
- DatagramHandler.new(self, server).run
113
+ DatagramHandler.new(self, server).run(wrapper)
114
when Socket::SOCK_STREAM
- StreamHandler.new(self, server).run
115
+ StreamHandler.new(self, server).run(wrapper)
116
else
117
raise ArgumentError.new("Don't know how to handle #{server}")
118
end
0 commit comments