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

Abstraction for types processing gateway identify requests.

Required Methods§

source

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§

source§

impl<T> Queue for &T
where T: Queue,

source§

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

Implementors§