Struct protosocket_prost::ClientRegistry

pub struct ClientRegistry { /* private fields */ }

The root IO tracker for a class of clients. You can use different kinds of clients with a single registry. The registry generates network status events for connections - readable & writable. Connections themselves service the events and invoke read/writev.

Implementations

impl ClientRegistry

pub fn new() -> Result<(Self, ClientRegistryDriver)>

Construct a new client registry. You will spawn the registry driver, probably on a dedicated thread.

pub fn set_max_message_length(&mut self, max_message_length: usize)

pub fn set_max_queued_outbound_messages( &mut self, max_queued_outbound_messages: usize, )

pub async fn register_client<Request, Response>( &self, address: impl Into<String>, ) -> Result<(Sender<Request>, Receiver<Response>, ConnectionDriver<ProstClientConnectionBindings<Request, Response>>)>

where Request: Message + Default + Unpin, Response: Message + Default + Unpin,

Get a new connection to a protosocket server.