Struct iterpipes::Composed

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

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::InputItem

The type of input this pipe accepts.

type OutputItem = P::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> 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.