Skip to main content

MpscFifoConsumer

subetha_cxc::mpsc_ring

Struct MpscFifoConsumer

pub struct MpscFifoConsumer { /* private fields */ }

Expand description

The single consumer handle. Uses the consumer-side SPSC fast path on the shared Vyukov ring; !Sync + !Clone + Send.

Implementations§

impl MpscFifoConsumer

pub fn try_pop(&self, out: &mut [u8]) -> Result<usize, RingError>

Pop one payload using the single-consumer fast path on the shared Vyukov ring. Skips the consumer-side CAS that the MPMC try_pop needs to defend against racing consumers. Sound here because the !Sync + !Clone type contract guarantees this is the only consumer.

Auto Trait Implementations§

impl !RefUnwindSafe for MpscFifoConsumer

impl !Sync for MpscFifoConsumer

impl !UnwindSafe for MpscFifoConsumer

impl Freeze for MpscFifoConsumer

impl Send for MpscFifoConsumer

impl Unpin for MpscFifoConsumer

impl UnsafeUnpin for MpscFifoConsumer

Blanket Implementations§

impl<T> Any for T
where T: 'static + ?Sized,

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more

impl<T> Borrow<T> for T
where T: ?Sized,

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more

impl<T> BorrowMut<T> for T
where T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more

impl<T> From<T> for T

fn from(t: T) -> T

Returns the argument unchanged.

impl<T, U> Into<U> for T
where U: From<T>,

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

impl<T, U> TryFrom<U> for T
where U: Into<T>,

type Error = Infallible

The type returned in the event of a conversion error.

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.