Trait apalis_core::worker::MessageResponse

pub trait MessageResponse<M: Message>: Send {
    fn handle<'async_trait>(
        self,
        sender: Sender<M::Result>
    ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>
    where
        Self: 'async_trait;
}

Available on crate feature worker only.

Dev trait for Message responding

Required Methods

fn handle<'async_trait>(
    self,
    sender: Sender<M::Result>
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>where
    Self: 'async_trait,

Handles message

Implementors

impl<M> MessageResponse<M> for M::Resultwhere
    M: Message,
    M::Result: Send,