Struct pipe_chain::pipe::Until

source · 
pub struct Until<P1, P2, O, O2>(/* private fields */);
Expand description

UntilExt::until implementation

Trait Implementations§

source§

impl<I, O, O2, E, P1, P2> Pipe<I, <(Vec<<O as Unpack>::Output>,) as Extend<O2>>::Output, E> for Until<P1, P2, O, O2>where I: Clone, O: Unpack, O2: HList, (Vec<O::Output>,): Extend<O2>, P1: Pipe<I, O, E>, P2: Pipe<I, O2, E>,

source§

fn apply( &mut self, input: I ) -> Result<I, <(Vec<O::Output>,) as Extend<O2>>::Output, E>

Produces a Result from an input Read more

Auto Trait Implementations§

§

impl<P1, P2, O, O2> RefUnwindSafe for Until<P1, P2, O, O2>where O: RefUnwindSafe, O2: RefUnwindSafe, P1: RefUnwindSafe, P2: RefUnwindSafe,

§

impl<P1, P2, O, O2> Send for Until<P1, P2, O, O2>where O: Send, O2: Send, P1: Send, P2: Send,

§

impl<P1, P2, O, O2> Sync for Until<P1, P2, O, O2>where O: Sync, O2: Sync, P1: Sync, P2: Sync,

§

impl<P1, P2, O, O2> Unpin for Until<P1, P2, O, O2>where O: Unpin, O2: Unpin, P1: Unpin, P2: Unpin,

§

impl<P1, P2, O, O2> UnwindSafe for Until<P1, P2, O, O2>where O: UnwindSafe, O2: UnwindSafe, P1: UnwindSafe, P2: UnwindSafe,

Blanket Implementations§

source§

impl<I, O, E, R, P> AndExt<I, O, E, R> for Pwhere P: Pipe<I, O, E, R>,

source§

fn and<O2, R2, P>(self, p: P) -> And<Self, P, O, O2, R>where Self: Sized, O: Extend<O2>, O2: HList, P: Pipe<R, O2, E, R2>,

Chains 2 Pipes one after another Read more
source§

fn and_other<O2, R2, P>(self, p: P) -> AndOther<Self, P, O, R>where Self: Sized, P: Pipe<R, O2, E, R2>,

Chains 2 Pipes one after another Read more
source§

fn and_self<O2, R2, P>(self, other: P) -> AndSelf<Self, P, R, O2>where Self: Sized, P: Pipe<R, O2, E, R2>,

Chains 2 Pipes one after another Read more
source§

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,

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>>,

Applies the given closure on the output of a pipe Read more
source§

fn ok_and_then<O2, R2, F>(self, other: F) -> OkAndThen<O, R, Self, F>where Self: Sized, F: FunMut<(R, O), Output = Result<(R2, O2), FatalError<E>>>,

Applies the given closure to the output and remaining input of a pipe Read more
source§

fn ok_then<O2, R2, P>(self, other: P) -> OkThen<O, R, Self, P>where Self: Pipe<I, O, E, R> + Sized, P: Pipe<(R, O), O2, E, R2> + Sized,

Applies the pipes consecutively Read more
source§

impl<T> Any for Twhere T: 'static + ?Sized,

source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
source§

impl<T> Borrow<T> for Twhere T: ?Sized,

source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
source§

impl<T> BorrowMut<T> for Twhere T: ?Sized,

source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
source§

impl<I, O, E, R, P> BoxedExt<I, O, E, R> for Pwhere P: Pipe<I, O, E, R>,

source§

fn boxed<'a>(self) -> BoxedPipe<'a, I, O, E, R>where Self: Pipe<I, O, E, R> + Sized + 'a,

Wraps the current Pipe into a Box Read more
source§

impl<I, O, E, R, P> EitherExt<I, O, E, R> for Pwhere P: Pipe<I, O, E, R>,

source§

fn either<O2, P>(self, p: P) -> EitherPipe<O, O2, Self, P>where I: Clone, Self: Pipe<I, O, E, R> + Sized, P: Pipe<I, O2, E, R>,

Combine 2 Pipes with the same input and remaining but differents outputs Read more
source§

fn either_full<O2, R2, P>(self, p: P) -> EitherPipeFull<O, O2, Self, P>where I: Clone, Self: Pipe<I, O, E, R> + Sized, P: Pipe<I, O2, E, R2>,

Combine 2 Pipes with the same input and differents outputs and remaining Read more
source§

impl<I, O, E, R, P> ErrExt<I, O, E, R> for Pwhere P: Pipe<I, O, E, R>,

source§

fn escalate(self) -> Escalate<Self>where Self: Sized,

Makes non fatal errors fatal
source§

fn deescalate(self) -> Deescalate<Self>where Self: Sized,

makes fatal errors non fatal
source§

impl<T> From<T> for T

source§

fn from(t: T) -> T

Returns the argument unchanged.

source§

impl<T, U> Into<U> for Twhere U: From<T>,

source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

source§

impl<I, O, E, R, P> MapExt<I, O, E, R> for Pwhere P: Pipe<I, O, E, R>,

source§

fn map<F>(self, f: F) -> Map<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. Read more
source§

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 more
source§

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 more
source§

fn map_err<E2, F>(self, f: F) -> MapErr<Self, F, E>where Self: Sized, F: FnMut(FatalError<E>) -> FatalError<E2>,

Maps an error FatalError<E> to FatalError<E2> by applying a function to the error. Read more
source§

impl<I, O, E, R, P> NotExt<I, O, E, R> for Pwhere P: Pipe<I, O, E, R>,

source§

fn not(self) -> Not<O, R, Self>where I: Clone, O: Debug, Self: Sized,

Fails if the given pipe succeeds
source§

impl<I, O, E, P> OptExt<I, O, E> for Pwhere P: Pipe<I, O, E>,

source§

fn opt(self) -> Opt<Self, O>where Self: Sized, I: Clone, O: Unpack,

Makes a Pipe optional if it returns a non fatal error Read more
source§

impl<I, O, E, R, P> OrExt<I, O, E, R> for Pwhere P: Pipe<I, O, E, R>,

source§

fn or<P>(self, p: P) -> Or<Self, P>where Self: Sized, I: Clone, P: Pipe<I, O, E, R>,

Apply the second Pipe if the first fails Read more
source§

fn or_self<O2, P>(self, p: P) -> OrSelf<O, O2, Self, P>where Self: Sized, O: Unpack, I: Clone, P: Pipe<I, O2, E, R>,

Apply the second Pipe if the first fails discarding the output of the second pipe Read more
source§

fn or_other<O2, P>(self, p: P) -> OrOther<O, O2, Self, P>where Self: Sized, I: Clone, O2: Unpack, P: Pipe<I, O2, E, R>,

Apply the second Pipe if the first fails discarding the output of the first pipe Read more
source§

impl<I, O, E, R, P> PeekExt<I, O, E, R> for Pwhere I: Clone, P: Pipe<I, O, E, R>,

source§

fn peek(self) -> Peek<Self, R>where Self: Sized, I: Clone,

Makes a Pipe optional if it returns a non fatal error Read more
source§

impl<I, O, E, P> RepeatExt<I, O, E> for Pwhere P: Pipe<I, O, E>,

source§

fn repeat<R>(self, r: R) -> RepeatPipe<Self, O>where R: TryInto<Repetition>, R::Error: Error, Self: Pipe<I, O, E> + Sized,

Repeats this pipe. Read more
source§

impl<I, O, E, R, P> SkipExt<I, O, E, R> for Pwhere P: Pipe<I, O, E, R>,

source§

fn skip(self) -> Skip<Self, O>where Self: Sized,

Discards the output of the pipe Read more
source§

fn and_skip<O2, R2, P>(self, other: P) -> AndSkip<Self, P, O, O2, R>where Self: Sized, P: Pipe<R, O2, E, R2>,

Chains 2 Pipes one after another both output are discarded Read more
source§

fn or_skip<O2, P>(self, p: P) -> OrSkip<O, O2, Self, P>where Self: Sized, I: Clone, P: Pipe<I, O2, E, R>,

Apply the second Pipe if the first fails discarding both output Read more
source§

impl<T, U> TryFrom<U> for Twhere U: Into<T>,

§

type Error = Infallible

The type returned in the event of a conversion error.
source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
source§

impl<T, U> TryInto<U> for Twhere U: TryFrom<T>,

§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
source§

impl<I, O, E, R, P> UnpackExt<I, O, E, R> for Pwhere P: Pipe<I, O, E, R>,

source§

fn unpack(self) -> UnpackPipe<Self, O>where O: Unpack, Self: Sized,

Unpacks the output of a pipe Read more
source§

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>,

Applies a Pipe until the 2nd succeeds
source§

fn no_more_until<O2, P>(self, p: P) -> NoMoreUntil<Self, P, O, O2>where I: Clone, O: Unpack, O2: HList, (Vec<O::Output>,): Extend<O2>, Self: Sized, P: Pipe<I, O2, E>,

Applies self until p succeeds, self is applied 0 or more times
source§

fn repeat_until<O2, R, P>(self, r: R, p: P) -> RepeatUntil<Self, P, O, O2>where I: Clone, O: Unpack, O2: HList, R: TryInto<Repetition>, R::Error: Error, (Vec<O::Output>,): Extend<O2>, Self: Sized, P: Pipe<I, O2, E>,

repeats self with the given repetition then applies p
source§

impl<I, O, E, R, P> WrapExt<I, O, E, R> for Pwhere P: Pipe<I, O, E, R>,

source§

fn wrap<I2, O2, R2, F>(self, f: F) -> Wrap<I, O, R, Self, F>where Self: Pipe<I, O, E, R> + Sized, F: FnMut(&mut Self, I2) -> Result<R2, O2, E>,

wraps self into a function Read more