Struct Subscription 

pub struct Subscription(/* private fields */);

An active subscription.

Implementations

impl Subscription

pub async fn pipe_from_stream<S, T, B>(&self, stream: S, buf: B)

where S: Stream<Item = T> + Unpin, T: Serialize + Send, B: Buffer<Item = T>,

Feed items to the subscription from the underlying stream with specified buffer strategy.

pub async fn pipe_from_try_stream<S, T, B, E>( &self, stream: S, buf: B, ) -> Result<(), E>

where S: TryStream<Ok = T, Error = E> + Unpin, T: Serialize + Send, B: Buffer<Item = T>,

Feed items to the subscription from the underlying stream with specified buffer strategy.

pub async fn send(&self, result: &impl Serialize) -> Result<(), DisconnectError>

Send a message on the subscription.

pub fn subscription_id(&self) -> SubscriptionId<'_>

Get the subscription id.

pub async fn closed(&self)

Completes when the subscription is closed.

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.

impl Debug for Subscription

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

Formats the value using the given formatter.

impl From<SubscriptionSink> for Subscription

fn from(sink: SubscriptionSink) -> Self

Converts to this type from the input type.