Struct MessagesManagerBuilder 

pub struct MessagesManagerBuilder {
    state: SubscriptionState,
    buffer_size: Option<usize>,
    autosubscribe: bool,
}

Builder for creating MessagesManager instances with persistent state support.

This builder allows you to configure the MessagesManager with previous state, buffer sizes, and other options before connecting to the message service.

Example

// Create with previous state
let previous_state = SubscriptionState::new();
let manager = MessagesManagerBuilder::new()
    .state(previous_state)
    .buffer_size(2000)
    .build(connection)
    .await?;

// Or create fresh
let manager = MessagesManagerBuilder::new()
    .build(connection)
    .await?;

Fields

state: SubscriptionState

Previous subscription state to restore

buffer_size: Option<usize>

Buffer size for the broadcast channel

autosubscribe: bool

whether to automatically issue the subscribe command at start

Implementations

impl MessagesManagerBuilder

pub fn new() -> Self

Create a new builder with default settings

pub fn state(self, state: SubscriptionState) -> Self

Set the subscription state to restore from

pub fn with_filters(self, filters: MessageFilters) -> Self

pub fn buffer_size(self, size: usize) -> Self

Set the buffer size for the broadcast channel

pub fn autosubscribe(self, autosubscribe: bool) -> Self

pub async fn build(self, connection: &Connection) -> Result<MessagesManager>

Build the MessagesManager by connecting to the service

This will:

1. Connect to the messages service
2. Restore previous subscription state if any
3. Start the message broadcasting
4. Return a fully configured MessagesManager

Trait Implementations

impl Debug for MessagesManagerBuilder

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

Formats the value using the given formatter.

impl Default for MessagesManagerBuilder

fn default() -> Self

Returns the “default value” for a type.