Struct Enumerate

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

A pipe that enumerates the output items of another pipe.

The inputs of this pipe are the same as the wrapped ones, but it’s output item is a tuple of an index and the wrapped pipe’s output. The index starts with zero and counts up for every produces output item.

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

Implementations

impl<P: Pipe> Enumerate<P>

pub fn new(pipe: P) -> Self

Create a new enumerating pipe.

Trait Implementations

impl<P: Pipe> Pipe for Enumerate<P>

type InputItem = <P as Pipe>::InputItem

The type of input this pipe accepts.

type OutputItem = (usize, <P as Pipe>::OutputItem)

The type of output this pipe produces.

fn next(&mut self, item: P::InputItem) -> (usize, 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 Enumerate<P>

fn reset(&mut self)

Reset the state of the pipe.