Trait MultiConsumerSpawner 

pub trait MultiConsumerSpawner<T> {
    type SpawnedConsumer: MultiConsumer<T>;

    // Required method
    fn spawn_multi_consumer(&self) -> Self::SpawnedConsumer;
}

A spawner of consumers for a multi-consumer queue.

Required Associated Types

type SpawnedConsumer: MultiConsumer<T>

An associated MultiConsumer type.

Required Methods

fn spawn_multi_consumer(&self) -> Self::SpawnedConsumer

Spawns a MultiConsumer.

Implementors

impl<T: Send, SC> MultiConsumerSpawner<T> for CachePaddedSPMCUnboundedProducer<T, SC>

where SC: SyncCell<LightArc<Version<T>>>,

type SpawnedConsumer = CachePaddedSPMCUnboundedConsumer<T, SC>

impl<T: Send, SC> MultiConsumerSpawner<T> for SPMCUnboundedProducer<T, SC>

where SC: SyncCell<LightArc<Version<T>>>,

type SpawnedConsumer = SPMCUnboundedConsumer<T, SC>

impl<T: Send, const CAPACITY: usize> MultiConsumerSpawner<T> for CachePaddedMPMCProducer<T, CAPACITY>

type SpawnedConsumer = CachePaddedMPMCConsumer<T, CAPACITY>

impl<T: Send, const CAPACITY: usize> MultiConsumerSpawner<T> for MPMCProducer<T, CAPACITY>

type SpawnedConsumer = MPMCConsumer<T, CAPACITY>

impl<T: Send, const CAPACITY: usize> MultiConsumerSpawner<T> for CachePaddedSPMCProducer<T, CAPACITY>

type SpawnedConsumer = CachePaddedSPMCConsumer<T, CAPACITY>

impl<T: Send, const CAPACITY: usize> MultiConsumerSpawner<T> for SPMCProducer<T, CAPACITY>

type SpawnedConsumer = SPMCConsumer<T, CAPACITY>