Struct SubOptions 

pub struct SubOptions { /* private fields */ }

Implementations

impl SubOptions

pub fn with_ingress_queue_size(self, ingress_queue_size: usize) -> Self

Sets the ingress queue size. This is the maximum amount of incoming messages that will be buffered. If the consumer cannot keep up with the incoming messages, messages will start being dropped.

Default: DEFAULT_QUEUE_SIZE

pub fn with_read_buffer_size(self, read_buffer_size: usize) -> Self

Sets the read buffer size. This sets the size of the read buffer for each session.

Default: DEFAULT_BUFFER_SIZE

pub fn with_initial_backoff(self, initial_backoff: Duration) -> Self

Set the initial backoff for reconnecting to a publisher.

pub fn with_retry_attempts(self, retry_attempts: usize) -> Self

Sets the maximum number of retry attempts. If None, the connection will retry indefinitely.

Trait Implementations

impl Clone for SubOptions

fn clone(&self) -> SubOptions

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SubOptions

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

Formats the value using the given formatter.

impl Default for SubOptions

fn default() -> Self

Returns the “default value” for a type.