Struct market::Collector

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

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

Implementations

impl<G, T> Collector<G, T> where
    T: 'static, 

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

Creates a new, empty Collector.

pub fn push<C>(&mut self, consumer: Rc<C>) where
    C: Consumer + 'static,
    G: From<C::Good> + 'static,
    T: From<C::Fault> + Error + 'static, 

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

Trait Implementations

impl<G, T> Consumer for Collector<G, T> where
    T: Error + 'static, 

type Good = G

The item being consumed.

type Fault = T

The fault that could be thrown during consumption.

fn consume(&self) -> Result<Self::Good, ConsumeFailure<Self::Fault>>

Retrieves the next good from the market without blocking.

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

Retrieves all goods held in the market without blocking.

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

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

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, T: Default> Default for Collector<G, T>

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

Returns the "default value" for a type.