Struct kernel::comms::kchannel::KProducer

pub struct KProducer<T> {
    q: Arc<MpScQueue<T, SpiteData<T>>>,
}

A Producer for a KChannel.

A KProducer can be cloned multiple times, as the backing KChannel is an MPSC queue.

Fields

q: Arc<MpScQueue<T, SpiteData<T>>>

Implementations

impl<T> KProducer<T>

pub fn enqueue_sync(&self, item: T) -> Result<(), EnqueueError<T>>

Attempt to immediately add an item to the end of the queue

Returns back the item if the queue is full

pub async fn enqueue_async(&self, item: T) -> Result<(), EnqueueError<T>>

Attempt to asynchronously add an item to the end of the queue.

If the queue is full, this method will yield until there is space available.

pub(crate) fn type_erase(self) -> ErasedKProducer

pub(crate) fn close(&mut self)

Trait Implementations

impl<T> Clone for KProducer<T>

fn clone(&self) -> Self

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.