Struct revenq::Queue

pub struct Queue<T> { /* fields omitted */ }

A simple event / revision queue

Trait Implementations

impl<T> Clone for Queue<T>

fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<T: Debug> Debug for Queue<T>

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

Formats the value using the given formatter.

impl<T> Default for Queue<T>

fn default() -> Self

Returns the "default value" for a type.

impl<T: Send + 'static> QueueInterface for Queue<T>

type Item = T

fn publish(&mut self, pending: T) -> Vec<RevisionRef<T>>

This method publishes the pending revision and returns all skipped revisions.

fn recv(&mut self) -> Vec<RevisionRef<T>>

Returns a list of newly published revisions.

fn new() -> Self