Struct Subscription

pub struct Subscription {
    pub channel: Mutex<String>,
    pub succeeded: Event,
    pub queue: SubscriptionQueue,
    /* private fields */
}

Fields

channel: Mutex<String>

succeeded: Event

queue: SubscriptionQueue

Implementations

impl Subscription

pub fn new( model: SubscriptionModel, event: SubscriptionEvent, filters: Object, channel: String, ) -> Self

pub async fn next(&self) -> Option<Object>

pub async fn push(&self, object: Object)

pub async fn extend(&self, iter: impl Iterator<Item = Object>)

Trait Implementations

impl Debug for Subscription

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

Formats the value using the given formatter.