Struct Connector

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

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

The type of input this pipe accepts.

type OutputItem = <P1 as Pipe>::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.