Struct apollo_router::layers::async_checkpoint::AsyncCheckpointLayer

pub struct AsyncCheckpointLayer<S, Fut, Request>where
    S: Service<Request, Error = BoxError> + Clone + Send + 'static,
    Fut: Future<Output = Result<ControlFlow<<S as Service<Request>>::Response, Request>, BoxError>>,{ /* private fields */ }

[Layer] for Asynchronous Checkpoints. See ServiceBuilderExt::checkpoint_async().

Implementations

impl<S, Fut, Request> AsyncCheckpointLayer<S, Fut, Request>where S: Service<Request, Error = BoxError> + Clone + Send + 'static, Fut: Future<Output = Result<ControlFlow<<S as Service<Request>>::Response, Request>, BoxError>>,

pub fn new<F>(checkpoint_fn: F) -> Selfwhere F: Fn(Request) -> Fut + Send + Sync + 'static,

Create an AsyncCheckpointLayer from a function that takes a Service Request and returns a ControlFlow

Trait Implementations

impl<S, Fut, Request> Layer<S> for AsyncCheckpointLayer<S, Fut, Request>where S: Service<Request, Error = BoxError> + Clone + Send + 'static, <S as Service<Request>>::Future: Send, Request: Send + 'static, <S as Service<Request>>::Response: Send + 'static, Fut: Future<Output = Result<ControlFlow<<S as Service<Request>>::Response, Request>, BoxError>>,

type Service = AsyncCheckpointService<S, Fut, Request>

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.