Struct market::Collector

pub struct Collector<G, E> { /* fields omitted */ }

A Consumer that consumes goods of type G from multiple Consumers.

Implementations

impl<G, E> Collector<G, E>

#[must_use]pub fn new() -> Self

Creates a new, empty Collector.

pub fn convert_into_and_push<C>(&mut self, consumer: C) where
    C: Consumer + 'static,
    G: From<C::Good> + 'static,
    E: From<C::Failure> + Error + 'static, 

Converts consumer to an appropriate type then pushes it.

pub fn push<C>(&mut self, consumer: C) where
    C: Consumer<Good = G, Failure = E> + 'static,
    E: Error, 

Adds consumer to the end of the Consumers held by self.

Trait Implementations

impl<G, E> Consumer for Collector<G, E> where
    E: Error, 

type Good = G

The type of the item being consumed.

type Failure = E

The type of the error that could be thrown during consumption.

fn consume(&self) -> Result<Self::Good, ConsumeError<Self::Failure>>

Retrieves the next good from the market without blocking.

fn consume_all(&self) -> Result<Vec<Self::Good>, ConsumeError<Self::Failure>>

Retrieves all goods held in the market without blocking.

fn demand(&self) -> Result<Self::Good, Self::Failure>

Retrieves the next good from the market, blocking until one is available.

fn adapt<G, F>(self) -> Adapter<Self, G, F> where
    Self: Sized, 

Creates an Adapter that converts each consumption by self to the appropriate G or F.

impl<G, E> Debug for Collector<G, E>

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

Formats the value using the given formatter.

impl<G: Default, E: Default> Default for Collector<G, E>

fn default() -> Collector<G, E>

Returns the "default value" for a type.