Struct Subscription 

pub struct Subscription {
    pub stream: String,
    pub symbol: String,
    pub sub_type: SubscriptionType,
    pub subscribed_at: Instant,
    /* private fields */
}

Subscription metadata

Fields

stream: String

Stream name (e.g. “btcusdt@ticker”)

symbol: String

Normalized trading symbol (e.g. “BTCUSDT”)

sub_type: SubscriptionType

Subscription type descriptor

subscribed_at: Instant

Timestamp when the subscription was created

Implementations

impl Subscription

pub fn new( stream: String, symbol: String, sub_type: SubscriptionType, sender: Sender<Value>, ) -> Self

Creates a new subscription with the provided parameters

pub fn add_sender(&self, sender: Sender<Value>)

Adds a new sender to this subscription for multi-subscriber support.

pub fn send(&self, message: Value) -> bool

Sends a message to all subscribers, removing closed senders.

Returns true if at least one sender successfully received the message.

pub fn add_ref(&self) -> usize

Increments the reference count and returns the new value

pub fn remove_ref(&self) -> usize

Decrements the reference count and returns the new value

pub fn ref_count(&self) -> usize

Returns the current reference count

Trait Implementations

impl Clone for Subscription

fn clone(&self) -> Subscription

Returns a duplicate of the value.

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

Performs copy-assignment from source.