Struct market::Distributor

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

Distributes goods to multiple producers.

Implementations

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

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

Creates a new, empty Distributor.

pub fn push<P>(&mut self, producer: Rc<P>) where
    P: Producer + 'static,
    G: TryInto<P::Good> + 'static,
    T: From<P::Fault> + Error + 'static, 

Adds producer to the end of the [Producers]s held by self.

Trait Implementations

impl<G, T> Debug for Distributor<G, T>

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

Formats the value using the given formatter.

impl<G, T> Default for Distributor<G, T>

fn default() -> Self

Returns the "default value" for a type.

impl<G, T> Producer for Distributor<G, T> where
    T: Error + 'static,
    G: Clone, 

type Good = G

The item being produced.

type Fault = T

The fault that could be thrown during production.

fn produce(&self, good: Self::Good) -> Result<(), ProduceFailure<Self::Fault>>

Stores good in the market without blocking.

fn produce_or_recall(
    &self,
    good: Self::Good
) -> Result<(), Recall<Self::Good, Self::Fault>> where
    Self::Good: Clone + Debug, 

Stores good in the market without blocking, returning good on failure.

fn produce_all(
    &self,
    goods: Vec<Self::Good>
) -> Result<(), ProduceFailure<Self::Fault>>

Stores each good in goods in the market without blocking.

fn force(&self, good: Self::Good) -> Result<(), Self::Fault> where
    Self::Good: Clone + Debug,
    Self::Fault: 'static, 

Stores good in the market, blocking until space is available.

fn force_all(&self, goods: Vec<Self::Good>) -> Result<(), Self::Fault> where
    Self::Good: Clone + Debug,
    Self::Fault: 'static, 

Stores every good in goods, blocking until space is available.