Trait Queue

pub trait Queue {
    // Required method
    fn enqueue(&self, id: u32) -> Receiver<()>;
}

Abstraction for types processing gateway identify requests.

Required Methods

fn enqueue(&self, id: u32) -> Receiver<()>

Enqueue a shard with this ID.

Send () to signal the shard to proceed. Note that shards may have dropped the receiver prior.

Closing the channel should causes the shard to requeue.

Implementations on Foreign Types

impl<T> Queue for &T

where T: Queue,

fn enqueue(&self, shard: u32) -> Receiver<()>

Implementors

impl Queue for InMemoryQueue