Struct Sub 

pub struct Sub<T> { /* private fields */ }

The consuming part of the pipework

Implementations

impl<T: Clone> Sub<T>

pub fn next(&mut self) -> Next<'_, T>

impl<T: Clone> Sub<T>

pub fn publish(&self) -> Pub<T>

pub fn try_pop(&mut self) -> Result<T, TryPopError>

Trait Implementations

impl<T> Clone for Sub<T>

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<T: Debug> Debug for Sub<T>

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

Formats the value using the given formatter.

impl<T> Default for Sub<T>

fn default() -> Self

Returns the “default value” for a type.

impl<T: Clone> Stream for Sub<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.