Struct actix_taskqueue::messages::Pop

pub struct Pop<T> { /* fields omitted */ }

Pop Message

The message that will be sent from consumers (workers) to get the next available task if exists.

Usage:

let msg = Pop::<i32>::new();

A PopError will be returned if there's no more task available in the queue.

Implementations

impl<T> Pop<T>

pub fn new() -> Pop<T>

Trait Implementations

impl<T: Clone> Clone for Pop<T>

fn clone(&self) -> Pop<T>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<T: Debug> Debug for Pop<T>

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

Formats the value using the given formatter.

impl<T: Default + Sized + Unpin + 'static> Handler<Pop<T>> for TaskQueue<T>

type Result = Result<T, PopError>

The type of value that this handler will return.

fn handle(&mut self, _: Pop<T>, _ctx: &mut Context<Self>) -> Self::Result

This method is called for every message received by this actor.

impl<T: 'static> Message for Pop<T>

type Result = Result<T, PopError>

The type of value that this message will resolved with if it is successful.