Struct Configuration 

pub struct Configuration<TStreamConnector> { /* private fields */ }

Configuration for a protosocket rpc client.

Implementations

impl<TStreamConnector> Configuration<TStreamConnector>

where TStreamConnector: StreamConnector,

pub fn new(stream_connector: TStreamConnector) -> Self

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

Max buffer length limits the max message size. Try to use a buffer length that is at least 4 times the largest message you want to support.

Default: 4MiB

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

Max messages that will be queued up waiting for send on the client channel.

Default: 256

pub fn buffer_allocation_increment( &mut self, buffer_allocation_increment: usize, )

Amount of buffer to allocate at one time when buffer needs extension.

Default: 1MiB

pub fn tcp_keepalive_duration( &mut self, tcp_keepalive_duration: Option<Duration>, )

The duration to set for tcp_keepalive on the underlying socket.

Default: None

Trait Implementations

impl<TStreamConnector: Clone> Clone for Configuration<TStreamConnector>

fn clone(&self) -> Configuration<TStreamConnector>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<TStreamConnector: Debug> Debug for Configuration<TStreamConnector>

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

Formats the value using the given formatter.