Struct StreamReceiver 

pub struct StreamReceiver<T: Send + 'static> { /* private fields */ }

A receiver handle given to the actor’s ReduceHandler.

The caller pushes items from a BoxStream into the channel; the actor consumes them through this receiver. Can be used directly with recv() or converted into a BoxStream via into_stream().

Implementations

impl<T: Send + 'static> StreamReceiver<T>

pub fn new(inner: Receiver<T>) -> Self

Create a new StreamReceiver wrapping a tokio mpsc receiver.

pub async fn recv(&mut self) -> Option<T>

Receive the next item, or None when the sender is closed.

pub fn into_stream(self) -> BoxStream<T>

Convert into a BoxStream for use with StreamExt combinators.