Method: Async::IO::Socket.accept

Defined in:
lib/async/io/socket.rb

.accept(*args, backlog: SOMAXCONN, &block) ⇒ Object

Bind to a local address and accept connections in a loop.



177
178
179
180
181
182
183
 
# File 'lib/async/io/socket.rb', line 177

def self.accept(*args, backlog: SOMAXCONN, &block)
	bind(*args) do |server, task|
		server.listen(backlog) if backlog
		
		server.accept_each(task: task, &block)
	end
end