Struct AckLayer

pub struct AckLayer<A, Req, Ctx, Cdc> { /* private fields */ }

A layer that acknowledges a job completed successfully

Implementations

impl<A, Req, Ctx, Cdc> AckLayer<A, Req, Ctx, Cdc>

pub fn new(ack: A) -> Self

Build a new AckLayer for a job

Trait Implementations

impl<A: Debug, Req: Debug, Ctx: Debug, Cdc: Debug> Debug for AckLayer<A, Req, Ctx, Cdc>

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

Formats the value using the given formatter.

impl<A, Req, Ctx, S, Cdc> Layer<S> for AckLayer<A, Req, Ctx, Cdc>

where S: Service<Request<Req, Ctx>> + Send + 'static, S::Error: Error + Send + Sync + 'static, S::Future: Send + 'static, A: Ack<Req, S::Response, Cdc> + Clone + Send + Sync + 'static,

type Service = AckService<S, A, Req, Ctx, Cdc>

The wrapped service

fn layer(&self, service: S) -> Self::Service

Wrap the given service with the middleware, returning a new service that has been decorated with the middleware.