Trait revenq::QueueInterface

pub trait QueueInterface: Clone + Default {
    type Item: Send + 'static;
    fn publish(&mut self, pending: Self::Item) -> Vec<RevisionRef<Self::Item>>;
    fn recv(&mut self) -> Vec<RevisionRef<Self::Item>>;

    fn new() -> Self { ... }
}

Common interface for all provided event / revision queues

Associated Types

type Item: Send + 'static

Loading content...

Required methods

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

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

fn recv(&mut self) -> Vec<RevisionRef<Self::Item>>

Returns a list of newly published revisions.

Loading content...

Provided methods

fn new() -> Self

Loading content...

Implementors

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

type Item = T

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

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

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

type Item = T

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

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

Loading content...