Struct ProcedureStreamMap

pub struct ProcedureStreamMap<F: FnMut(Result<DynOutput<'_>, ProcedureError>) -> Result<T, String>, T> { /* private fields */ }

Implementations

impl<F: FnMut(Result<DynOutput<'_>, ProcedureError>) -> Result<T, String>, T> ProcedureStreamMap<F, T>

pub fn stream(&mut self)

Start streaming data. Refer to Self::require_manual_stream for more information.

pub fn resolved(&self) -> bool

Will return true if the future has resolved.

For a stream created via Self::from_future* this will be true once the future has resolved and for all other streams this will always be true.

pub fn flushable(&self) -> bool

Will return true if the stream is ready to start streaming data.

This is false until the flush function is called by the user.

Trait Implementations

impl<F: FnMut(Result<DynOutput<'_>, ProcedureError>) -> Result<T, String> + Unpin, T> Stream for ProcedureStreamMap<F, 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.