Struct indicator::async_operator::next::Next

pub struct Next<P> { /* private fields */ }

Next operator that converts a blocking Operator into an AsyncOperator.

Trait Implementations

impl<P, I, O> AsyncOperator<I> for Next<P>where
    P: Operator<I, Output = O>,

type Output = O

Output type.

type Error = Infallible

Error type.

type Future<'a>
where
    P: 'a = Ready<Result<<Next<P> as AsyncOperator<I>>::Output, <Next<P> as AsyncOperator<I>>::Error>>

The future output value.

fn poll_ready(&mut self, _cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>>

Check if the operator is ready to process the next input.

fn next(&mut self, input: I) -> Self::Future<'_>

Process the next input.

impl<P: Clone> Clone for Next<P>

fn clone(&self) -> Next<P>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<P: Debug> Debug for Next<P>

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

Formats the value using the given formatter.

impl<P: Copy> Copy for Next<P>