Struct Composed

pub struct Composed<P>
where
    P: Pipe,
{ /* private fields */ }

A composable or composed pipe.

This struct is an implementation of the newtype pattern to implement the >> operator for pipes (manifested as the Shr trait).

For more information, please see the documentation of the compose method.

Implementations

impl<P> Composed<P>

where P: Pipe,

pub fn new(pipe: P) -> Self

Create new composable or composed pipe.

pub fn unwrap(self) -> P

Unwrap the inner pipe.

Trait Implementations

impl<P> Pipe for Composed<P>

where P: Pipe,

type InputItem = <P as Pipe>::InputItem

The type of input this pipe accepts.

type OutputItem = <P as Pipe>::OutputItem

The type of output this pipe produces.

fn next(&mut self, item: P::InputItem) -> P::OutputItem

Calculate the next output item, based on an input item.

fn bypass(self) -> Bypass<Self>

where Self: Sized, Self::InputItem: Clone,

Create a bypassed version of the pipe.

fn compose(self) -> Composed<Self>

where Self: Sized,

Create a composable pipe.

fn connect<O: Pipe<InputItem = Self::OutputItem>>( self, other: O, ) -> Connector<Self, O>

where Self: Sized,

Connect two pipes.

fn into_iter(self) -> IterPipe<Self>

where Self::InputItem: Default, Self: Sized + Pipe<InputItem = ()>,

Wrap the pipe into an iterator.

fn optional(self) -> Optional<Self>

where Self: Sized,

Optionalize the pipe.

fn enumerate(self) -> Enumerate<Self>

where Self: Sized,

Enumerate the output items of a pipe.

fn boxed( self, ) -> Box<dyn Pipe<InputItem = Self::InputItem, OutputItem = Self::OutputItem>>

where Self: Sized + 'static,

Create a boxed trait object of the pipe.

impl<P> ResetablePipe for Composed<P>

where P: ResetablePipe,

fn reset(&mut self)

Reset the state of the pipe.

impl<P0, P1> Shr<P1> for Composed<P0>

where P0: Pipe, P1: Pipe<InputItem = P0::OutputItem>,

type Output = Composed<Connector<P0, P1>>

The resulting type after applying the >> operator.

fn shr(self, other: P1) -> Self::Output

Performs the >> operation.