Struct ClientRegistry 

pub struct ClientRegistry<TConnector = TcpConnector> { /* private fields */ }

A factory for creating client connections to a protosocket server.

Implementations

impl<TConnector> ClientRegistry<TConnector>

where TConnector: StreamConnector,

pub fn new(runtime: Handle, connector: TConnector) -> 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<TConnector: Clone> Clone for ClientRegistry<TConnector>

fn clone(&self) -> ClientRegistry<TConnector>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<TConnector: Debug> Debug for ClientRegistry<TConnector>

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

Formats the value using the given formatter.