Struct Pusher

pub struct Pusher<I>(/* private fields */);

The transmitting end-point of queue.

Implementations

impl<I> Pusher<I>

pub fn push(&self, item: I) -> Result<(), StaleErr>

Push a node on to the queue and unlock one queue reader, if any.

If there are any tasks or threads waiting for new nodes to arrive they will be notified.

Errors

StaleErr means there are no Puller’s available to receive any new nodes.

pub fn was_empty(&self) -> bool

Returns a boolean indicating whether the queue was empty or not.

This function is not particularly useful. If you don’t understand why, then please don’t use it.

pub fn weak(&self) -> WeakPusher<I>

Create a weak reference to this Pusher.

Trait Implementations

impl<I> Clone for Pusher<I>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<I> Drop for Pusher<I>

fn drop(&mut self)

Drop a Pusher instance.

When the final instance of a sigq’s instance’s Pusher is dropped, wake up any Puller’s waiting for new nodes to arrive.