class Endpoint
This is an endpoint which bridges a client with a local server.
Definitions
def run(parent: Task.current, &block)
Processing incoming connections
Implementation
def run(parent: Task.current, &block)
while peer = @queue.dequeue
server = @protocol.server(peer)
parent.async do
server.each(&block)
end
end
end