Struct Subscription 

pub struct Subscription<Notif> { /* private fields */ }

Active subscription on the client.

It will automatically unsubscribe in the Subscription::drop so no need to explicitly call the unsubscribe method if it is an an subscription based on SubscriptionId.

Implementations

impl<Notif> Subscription<Notif>

pub fn new( to_back: Sender<FrontToBack>, notifs_rx: Receiver<Value>, kind: SubscriptionKind, ) -> Subscription<Notif>

Create a new subscription.

impl<Notif> Subscription<Notif>

where Notif: DeserializeOwned,

pub async fn next(&mut self) -> Result<Option<Notif>, Error>

Returns the next notification from the stream. This may return Ok(None) if the subscription has been terminated, may happen if the channel becomes full or is dropped.

Trait Implementations

impl<Notif> Debug for Subscription<Notif>

where Notif: Debug,

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

Formats the value using the given formatter.

impl<Notif> Drop for Subscription<Notif>

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.