Struct pipelines::Receiver

pub struct Receiver<In> { /* fields omitted */ }

Passed to pipelines as their place to get incoming data from the previous stage.

It's possible to use by calling recv directly, but is primarily for its into_iter

Methods

impl<In> Receiver<In>

fn recv(&mut self) -> Option<In>

Get an item from the previous stage

returns None if the remote side has hung up and all data has been received

Trait Implementations

impl<In: Debug> Debug for Receiver<In>

fn fmt(&self, __arg_0: &mut Formatter) -> Result

Formats the value using the given formatter.

impl<In> IntoIterator for Receiver<In>

type Item = In

The type of the elements being iterated over.

type IntoIter = ReceiverIntoIterator<In>

Which kind of iterator are we turning this into?

fn into_iter(self) -> Self::IntoIter

Creates an iterator from a value.