Struct market::UnlimitedQueue

pub struct UnlimitedQueue<G> { /* fields omitted */ }

Defines a queue with unlimited size that implements Consumer and Producer.

An UnlimitedQueue can be closed, which prevents the Producer from producing new goods while allowing the Consumer to consume only the remaining goods on the queue.

Methods

impl<G> UnlimitedQueue<G>

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

Creates a new empty UnlimitedQueue.

pub fn close(&self)

Closes self.

Trait Implementations

impl<G> Consumer for UnlimitedQueue<G>

type Good = G

The item being consumed.

type Error = ClosedMarketError

The error when Self is not functional.

fn consume(&self) -> Result<Option<Self::Good>, Self::Error>

Attempts to retrieve the next good from the market without blocking.

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

Retrieves the next good from the market, blocking if needed.

fn goods(&self) -> GoodsIter<Self> where
    Self: Sized, 

Creates a blocking iterator that yields goods from the market.

impl<G: Debug> Debug for UnlimitedQueue<G>

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

Formats the value using the given formatter.

impl<G> Default for UnlimitedQueue<G>

fn default() -> Self

Returns the "default value" for a type.

impl<G> Producer for UnlimitedQueue<G>

type Good = G

The item being produced.

type Error = ClosedMarketError

The error when Self is not functional.

fn produce(&self, good: Self::Good) -> Result<Option<Self::Good>, Self::Error>

Attempts to add good to the market without blocking.

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

Attempts to add each good in goods to the market without blocking.

fn force(&self, good: Self::Good) -> Result<(), Self::Error>

Adds good to the market, blocking if needed.