Struct pipe_chain::pipe::RepeatPipe
source · pub struct RepeatPipe<P, O> { /* private fields */ }Expand description
RepeatExt::repeat implementation
Trait Implementations§
Auto Trait Implementations§
impl<P, O> RefUnwindSafe for RepeatPipe<P, O>where O: RefUnwindSafe, P: RefUnwindSafe,
impl<P, O> Send for RepeatPipe<P, O>where O: Send, P: Send,
impl<P, O> Sync for RepeatPipe<P, O>where O: Sync, P: Sync,
impl<P, O> Unpin for RepeatPipe<P, O>where O: Unpin, P: Unpin,
impl<P, O> UnwindSafe for RepeatPipe<P, O>where O: UnwindSafe, P: UnwindSafe,
Blanket Implementations§
source§impl<I, O, E, R, P> AndExt<I, O, E, R> for Pwhere
P: Pipe<I, O, E, R>,
impl<I, O, E, R, P> AndExt<I, O, E, R> for Pwhere P: Pipe<I, O, E, R>,
source§impl<I, O, E, R, P> AndThenExt<I, O, E, R> for Pwhere
P: Pipe<I, O, E, R>,
impl<I, O, E, R, P> AndThenExt<I, O, E, R> for Pwhere P: Pipe<I, O, E, R>,
source§fn and_then<O2, F>(self, f: F) -> AndThen<O, Self, F>where
Self: Sized,
F: FunMut<O, Output = Result<O2, FatalError<E>>>,
O: HList,
O2: HList,
fn and_then<O2, F>(self, f: F) -> AndThen<O, Self, F>where Self: Sized, F: FunMut<O, Output = Result<O2, FatalError<E>>>, O: HList, O2: HList,
Applies the given closure on the output of the pipe Read more
source§fn and_thenf<O2, F>(self, f: F) -> AndThenF<O, Self, F>where
Self: Sized,
F: FnMut(O) -> Result<O2, FatalError<E>>,
fn and_thenf<O2, F>(self, f: F) -> AndThenF<O, Self, F>where Self: Sized, F: FnMut(O) -> Result<O2, FatalError<E>>,
Applies the given closure on the output of a pipe Read more
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
source§impl<I, O, E, R, P> EitherExt<I, O, E, R> for Pwhere
P: Pipe<I, O, E, R>,
impl<I, O, E, R, P> EitherExt<I, O, E, R> for Pwhere P: Pipe<I, O, E, R>,
source§impl<I, O, E, R, P> ErrExt<I, O, E, R> for Pwhere
P: Pipe<I, O, E, R>,
impl<I, O, E, R, P> ErrExt<I, O, E, R> for Pwhere P: Pipe<I, O, E, R>,
source§fn deescalate(self) -> Deescalate<Self>where
Self: Sized,
fn deescalate(self) -> Deescalate<Self>where Self: Sized,
makes fatal errors non fatal
source§impl<I, O, E, R, P> MapExt<I, O, E, R> for Pwhere
P: Pipe<I, O, E, R>,
impl<I, O, E, R, P> MapExt<I, O, E, R> for Pwhere P: Pipe<I, O, E, R>,
source§fn map1<F>(self, f: F) -> Map1<Self, F, O>where
Self: Sized,
O: HList,
F: FunMut<O>,
fn map1<F>(self, f: F) -> Map1<Self, F, O>where Self: Sized, O: HList, F: FunMut<O>,
Maps the output of a pipe
O to O2 by applying a function to it.
The result is mapped into a tuple Read moresource§fn mapf<O2, F>(self, f: F) -> MapF<Self, F, O>where
Self: Sized,
F: FnMut(O) -> O2,
fn mapf<O2, F>(self, f: F) -> MapF<Self, F, O>where Self: Sized, F: FnMut(O) -> O2,
Maps the output of a pipe
O to O2 by applying a function to it.
The result is mapped into a tuple Read moresource§fn map_err<E2, F>(self, f: F) -> MapErr<Self, F, E>where
Self: Sized,
F: FnMut(FatalError<E>) -> FatalError<E2>,
fn map_err<E2, F>(self, f: F) -> MapErr<Self, F, E>where Self: Sized, F: FnMut(FatalError<E>) -> FatalError<E2>,
source§impl<I, O, E, R, P> OrExt<I, O, E, R> for Pwhere
P: Pipe<I, O, E, R>,
impl<I, O, E, R, P> OrExt<I, O, E, R> for Pwhere P: Pipe<I, O, E, R>,
source§impl<I, O, E, R, P> SkipExt<I, O, E, R> for Pwhere
P: Pipe<I, O, E, R>,
impl<I, O, E, R, P> SkipExt<I, O, E, R> for Pwhere P: Pipe<I, O, E, R>,
source§impl<I, O, E, P> UntilExt<I, O, E> for Pwhere
P: Pipe<I, O, E>,
impl<I, O, E, P> UntilExt<I, O, E> for Pwhere P: Pipe<I, O, E>,
source§fn until<O2, P>(self, p: P) -> Until<Self, P, O, O2>where
I: Clone,
O: Unpack,
O2: HList,
(Vec<O::Output>,): Extend<O2>,
Self: Sized,
P: Pipe<I, O2, E>,
fn until<O2, P>(self, p: P) -> Until<Self, P, O, O2>where I: Clone, O: Unpack, O2: HList, (Vec<O::Output>,): Extend<O2>, Self: Sized, P: Pipe<I, O2, E>,
Applies a Pipe until the 2nd succeeds