Struct FlowSubscriber

pub struct FlowSubscriber<T: Flows> { /* private fields */ }

Subscriber which receives data from a Flow.

Implementations

impl<T: Flows> FlowSubscriber<T>

pub fn try_next(&mut self) -> Result<impl Deref<Target = T> + '_, Error>

Returns a reference to the next data in the flow, if the flow is active and any data is available.

pub fn next( &mut self, ) -> impl Future<Output = Result<impl Deref<Target = T> + '_, Error>>

Awaits and returns a reference to the next data in the flow, if the flow is active.

Trait Implementations

impl<T> Debug for FlowSubscriber<T>

where T: Flows,

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

Formats the value using the given formatter.

impl<T: Flows> From<FlowSubscriber<T>> for Stage<T>

fn from(value: FlowSubscriber<T>) -> Self

Converts to this type from the input type.