Struct tokio_stream::wrappers::ReceiverStream

pub struct ReceiverStream<T> { /* fields omitted */ }

A wrapper around tokio::sync::mpsc::Receiver that implements Stream.

Implementations

impl<T> ReceiverStream<T>

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

Create a new ReceiverStream.

pub fn into_inner(self) -> Receiver<T>

Get back the inner Receiver.

pub fn close(&mut self)

Closes the receiving half of a channel without dropping it.

This prevents any further messages from being sent on the channel while still enabling the receiver to drain messages that are buffered. Any outstanding Permit values will still be able to send messages.

To guarantee no messages are dropped, after calling close(), you must receive all items from the stream until None is returned.

Trait Implementations

impl<T> AsMut<Receiver<T>> for ReceiverStream<T>

fn as_mut(&mut self) -> &mut Receiver<T>

Performs the conversion.

impl<T> AsRef<Receiver<T>> for ReceiverStream<T>

fn as_ref(&self) -> &Receiver<T>

Performs the conversion.

impl<T: Debug> Debug for ReceiverStream<T>

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

Formats the value using the given formatter.

impl<T> From<Receiver<T>> for ReceiverStream<T>

fn from(recv: Receiver<T>) -> Self

Performs the conversion.

impl<T> Stream for ReceiverStream<T>

type Item = T

Values yielded by the stream.

fn poll_next(
    self: Pin<&mut Self>,
    cx: &mut Context<'_>
) -> Poll<Option<Self::Item>>

Attempt to pull out the next value of this stream, registering the current task for wakeup if the value is not yet available, and returning None if the stream is exhausted.

fn size_hint(&self) -> (usize, Option<usize>)

Returns the bounds on the remaining length of the stream.