Trait Acknowledge 

pub trait Acknowledge<Res, Ctx, IdType> {
    type Error;
    type Future: Future<Output = Result<(), Self::Error>>;

    // Required method
    fn ack(
        &mut self,
        res: &Result<Res, BoxDynError>,
        ctx: &Parts<Ctx, IdType>,
    ) -> Self::Future;
}

Acknowledge the result of a task processing

See module level documentation for more details.

Required Associated Types

type Error

The error type returned by the acknowledgment process

type Future: Future<Output = Result<(), Self::Error>>

The future returned by the ack method

Required Methods

fn ack( &mut self, res: &Result<Res, BoxDynError>, ctx: &Parts<Ctx, IdType>, ) -> Self::Future

Acknowledge the result of a task processing

Implementors

impl<Res, Ctx, F, Fut, IdType, E> Acknowledge<Res, Ctx, IdType> for F

where F: FnMut(&Result<Res, BoxDynError>, &Parts<Ctx, IdType>) -> Fut, Fut: Future<Output = Result<(), E>>,

type Error = E

type Future = Fut