Struct protosocket_server::ConnectionServer

pub struct ConnectionServer<Connector: ServerConnector> { /* private fields */ }

A ConnectionServer is an IO driver. It directly uses mio to poll the OS’s io primitives, manages read and write buffers, and vends messages to & from connections. Connections interact with the ConnectionServer through mpsc channels.

Protosockets are monomorphic messages - you can only have 1 kind of message per service. The expected way to work with this is to use prost and protocol buffers to encode messages.

Protosocket messages are not opinionated about request & reply. If you are, you will need to implement such a thing. This allows you freely choose whether you want to send fire-&-forget messages sometimes; however it requires you to write your protocol’s rules. You get an inbound stream of and an outbound stream of per connection - you decide what those streams mean for you!

Trait Implementations

impl<Connector: ServerConnector> Future for ConnectionServer<Connector>

type Output = ()

The type of value produced on completion.

fn poll(self: Pin<&mut Self>, context: &mut Context<'_>) -> Poll<Self::Output>

Attempts to resolve the future to a final value, registering the current task for wakeup if the value is not yet available.