Struct iterpipes::Connector

pub struct Connector<P0, P1> where
    P0: Pipe,
    P1: Pipe<InputItem = P0::OutputItem>,  { /* fields omitted */ }

A pipe that connects two other pipes together.

The input item of this connector is the input item of P0 and its output item is the output item of P1. It calculates the output item of P0 and feeds it directly into P1.

Obviously, the output item of P0 has to match the input item of P1.

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

Implementations

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

pub fn new(pipe0: P0, pipe1: P1) -> Self

Create a new connector with the two pipes.

Trait Implementations

impl<P0, P1> Pipe for Connector<P0, P1> where
    P0: Pipe,
    P1: Pipe<InputItem = P0::OutputItem>, 

type InputItem = P0::InputItem

The type of input this pipe accepts.

type OutputItem = P1::OutputItem

The type of output this pipe produces.

fn next(&mut self, input: Self::InputItem) -> Self::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<P0, P1> ResetablePipe for Connector<P0, P1> where
    P0: ResetablePipe,
    P1: ResetablePipe<InputItem = P0::OutputItem>, 

fn reset(&mut self)

Reset the state of the pipe.