Method: Roby::Interface::TCPServer#queue_accept_future

Defined in:
lib/roby/interface/tcp.rb

#queue_accept_future ⇒ Object 



53
54
55
56
57
58
59
 
# File 'lib/roby/interface/tcp.rb', line 53

def queue_accept_future
    Concurrent::Future.execute(executor: @accept_executor) do
        socket = @server.accept
        socket.setsockopt(Socket::IPPROTO_TCP, Socket::TCP_NODELAY, true)
        socket
    end
end