Struct redis_queue_rs::async_redis_queue::AsyncRedisQueue

pub struct AsyncRedisQueue { /* private fields */ }

Implementations

impl AsyncRedisQueue

pub async fn new(queue_name: String, redis_client: Client) -> AsyncRedisQueue

pub async fn push<T>(&mut self, item: T)

where T: Clone + Serialize + for<'de> Deserialize<'de>,

pub async fn pop<T>(&mut self) -> Option<T>

where T: Clone + Serialize + for<'de> Deserialize<'de>,

Trait Implementations

impl Clone for AsyncRedisQueue

fn clone(&self) -> AsyncRedisQueue

Returns a copy of the value.

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

Performs copy-assignment from source.