Struct Worker 

pub struct Worker { /* private fields */ }

A worker that processes tasks from the queue.

Implementations

impl Worker

pub fn subscribed_types(&self) -> Vec<String>

Returns the task types this worker is subscribed to.

pub fn is_running(&self) -> bool

Returns whether the worker is running.

pub fn stop(&self)

Stops the worker.

pub async fn process_one(&self, cx: &Cx) -> DocketResult<bool>

Processes a single task if available.

Returns true if a task was processed, false if no task was available.

pub async fn run(&self, cx: &Cx) -> DocketResult<()>

Runs the worker loop until stopped.

Trait Implementations

impl Debug for Worker

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.