Struct ClientRegistry

pub struct ClientRegistry { /* private fields */ }

A factory for creating client connections to a protosocket server.

Implementations

impl ClientRegistry

pub fn new(runtime: Handle) -> Self

Construct a new client registry. Connections will be spawned on the provided runtime.

pub fn set_max_read_buffer_length(&mut self, max_buffer_length: usize)

Sets the maximum read buffer length for connections created by this registry after the setting is applied.

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

Sets the maximum queued outbound messages for connections created by this registry after the setting is applied.

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

where Request: Message + Default + Unpin + 'static, Response: Message + Default + Unpin + 'static, Reactor: MessageReactor<Inbound = Response>,

Get a new connection to a protosocket server.

Trait Implementations

impl Clone for ClientRegistry

fn clone(&self) -> ClientRegistry

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for ClientRegistry

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.