Skip to main content

TaskQueue

Trait TaskQueue 

Source
pub trait TaskQueue: Send + Sync {
    // Required method
    fn enqueue<T: Task>(
        &self,
        task: T,
    ) -> impl Future<Output = Result<TaskId, TaskQueueError>> + Send;
}
Expand description

Durable task queue. Implementations (Redis, RabbitMQ, …) ship later.

Required Methods§

Source

fn enqueue<T: Task>( &self, task: T, ) -> impl Future<Output = Result<TaskId, TaskQueueError>> + Send

Persist task and return its identifier.

Dyn Compatibility§

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors§