Struct UnboundedChannelSubscription 

pub struct UnboundedChannelSubscription<M> { /* private fields */ }

A subscription that receives messages from an unbounded channel.

This is the unbounded counterpart of ChannelSubscription. Use this when the sender should never block, at the cost of unbounded memory growth if messages are produced faster than consumed.

Example

use envision::app::UnboundedChannelSubscription;

let (tx, rx) = tokio::sync::mpsc::unbounded_channel::<String>();
let subscription = UnboundedChannelSubscription::new(rx);

Implementations

impl<M> UnboundedChannelSubscription<M>

pub fn new(receiver: UnboundedReceiver<M>) -> Self

Creates a subscription from an unbounded channel receiver.

Trait Implementations

impl<M: Send + 'static> Subscription<M> for UnboundedChannelSubscription<M>

fn into_stream( self: Box<Self>, cancel: CancellationToken, ) -> Pin<Box<dyn Stream<Item = M> + Send>>

Converts this subscription into a stream of messages.