Struct ArcBBQueue 

pub struct ArcBBQueue<S, C, N>(/* private fields */);

A BBQueue wrapped in an Arc

Implementations

impl<S: Storage, C: Coord, N: Notifier> ArcBBQueue<S, C, N>

pub fn new_with_storage(sto: S) -> Self

Create a new BBQueue with the given Storage impl

impl<S: Storage, C: Coord, N: Notifier> ArcBBQueue<S, C, N>

pub fn framed_producer(&self) -> FramedProducer<Arc<BBQueue<S, C, N>>>

Create a new FramedProducer for this BBQueue

Although mixing stream and framed consumer/producers will not result in UB, it will also not work correctly.

pub fn framed_consumer(&self) -> FramedConsumer<Arc<BBQueue<S, C, N>>>

Create a new FramedConsumer for this BBQueue

Although mixing stream and framed consumer/producers will not result in UB, it will also not work correctly.

pub fn stream_producer(&self) -> StreamProducer<Arc<BBQueue<S, C, N>>>

Create a new StreamProducer for this BBQueue

Although mixing stream and framed consumer/producers will not result in UB, it will also not work correctly.

pub fn stream_consumer(&self) -> StreamConsumer<Arc<BBQueue<S, C, N>>>

Create a new StreamConsumer for this BBQueue

Although mixing stream and framed consumer/producers will not result in UB, it will also not work correctly.