Struct Subscription 

pub struct Subscription {
    pub stream: String,
    pub symbol: String,
    pub sub_type: SubscriptionType,
    pub subscribed_at: Instant,
    pub sender: UnboundedSender<Value>,
}

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

sender: UnboundedSender<Value>

Sender for forwarding WebSocket messages to consumers

Implementations

impl Subscription

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

Creates a new subscription with the provided parameters

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

Sends a message to the subscriber

Arguments

• message - WebSocket payload to forward

Returns

Whether the message was delivered successfully

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.