Struct kernel::queues::publisher::Subscriber

pub struct Subscriber<T> {
    pub token: usize,
    // some fields omitted
}

Fields

token: usize

Methods

impl<T> Subscriber<T>

fn new(
    ring: Arc<RingBuffer<T>>,
    cursors: UncheckedUnsafeArc<Vec<Cursor>>,
    token: usize
) -> Self

fn recv(&self) -> Option<&T>

fn recv_n(&self, n: usize) -> Option<&[T]>

fn recv_all(&self) -> Option<&[T]>

fn commit(&self)

Trait Implementations

impl<T> Debug for Subscriber<T>

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

Formats the value using the given formatter.

impl<T: Send> Send for Subscriber<T>

impl<T> !Sync for Subscriber<T>

impl<T> Clone for Subscriber<T>

fn clone(&self) -> Subscriber<T>

Returns a copy of the value.

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

Performs copy-assignment from source.