ServerBuilder
Accept
WorkerClient
Worker
Dispatcher
start(socks, workers)
accept Connections
poll() --> Conn
backpressure logic
send(Conn)
loop
[ poll connections on sockets ]
process Connections
rx.poll_next()
Service factories
new(stream)
loop
[ Worker as Future::poll ]
process Requests
Dispatch requests
loop
[ Dispatcher::poll ]
ServerBuilder
Accept
WorkerClient
Worker
Dispatcher