Struct SubscriptionConfig 

pub struct SubscriptionConfig {
    pub channel: String,
    pub token: Option<Sensitive<String>>,
    pub data: Option<Vec<u8>>,
    pub positioned: bool,
    pub recoverable: bool,
    pub join_leave: bool,
    pub delta: Option<String>,
    pub tags_filter: Option<SubscriptionFilter>,
    pub min_resubscribe_delay: Duration,
    pub max_resubscribe_delay: Duration,
}

Channel subscription options and recovery settings.

Fields

channel: String

token: Option<Sensitive<String>>

data: Option<Vec<u8>>

positioned: bool

recoverable: bool

join_leave: bool

delta: Option<String>

tags_filter: Option<SubscriptionFilter>

min_resubscribe_delay: Duration

max_resubscribe_delay: Duration

Implementations

impl SubscriptionConfig

pub fn new(channel: impl Into<String>) -> Self

Creates default subscription settings for channel.

pub fn token(self, token: impl Into<String>) -> Self

Sets the private-channel token.

pub fn data(self, data: Vec<u8>) -> Self

Sets application data sent with the subscribe command.

pub fn positioned(self, enabled: bool) -> Self

Enables or disables stream-position information.

pub fn recoverable(self, enabled: bool) -> Self

Enables or disables stream recovery after reconnecting.

pub fn join_leave(self, enabled: bool) -> Self

Enables or disables join and leave publications.

pub fn delta(self, format: impl Into<String>) -> Self

Requests the named delta-compression format.

pub fn tags_filter(self, filter: SubscriptionFilter) -> Self

Sets the server-side publication tag filter.

Trait Implementations

impl Clone for SubscriptionConfig

fn clone(&self) -> SubscriptionConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SubscriptionConfig

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

Formats the value using the given formatter.