Trait Middleware

pub trait Middleware<M: Metadata>:
    Send
    + Sync
    + 'static {
    type Future: Future<Item = Option<Response>, Error = ()> + Send + 'static;

    // Required method
    fn on_request<F, X>(
        &self,
        request: Request,
        meta: M,
        next: F,
    ) -> Self::Future
       where F: FnOnce(Request, M) -> X + Send,
             X: Future<Item = Option<Response>, Error = ()> + Send + 'static;
}

RPC middleware

Required Associated Types

type Future: Future<Item = Option<Response>, Error = ()> + Send + 'static

A returned future.

Required Methods

fn on_request<F, X>(&self, request: Request, meta: M, next: F) -> Self::Future

where F: FnOnce(Request, M) -> X + Send, X: Future<Item = Option<Response>, Error = ()> + Send + 'static,

Msod invoked on each request. Allows you to either respond directly (without executing RPC call) or do any additional work before and/or after processing the request.

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

Implementations on Foreign Types

impl<M: Metadata, A: Middleware<M>, B: Middleware<M>> Middleware<M> for (A, B)

type Future = <A as Middleware<M>>::Future

fn on_request<F, X>( &self, request: Request, meta: M, process: F, ) -> Self::Future

where F: FnOnce(Request, M) -> X + Send, X: Future<Item = Option<Response>, Error = ()> + Send + 'static,

impl<M: Metadata, A: Middleware<M>, B: Middleware<M>, C: Middleware<M>> Middleware<M> for (A, B, C)

type Future = <A as Middleware<M>>::Future

fn on_request<F, X>( &self, request: Request, meta: M, process: F, ) -> Self::Future

where F: FnOnce(Request, M) -> X + Send, X: Future<Item = Option<Response>, Error = ()> + Send + 'static,

impl<M: Metadata, A: Middleware<M>, B: Middleware<M>, C: Middleware<M>, D: Middleware<M>> Middleware<M> for (A, B, C, D)

type Future = <A as Middleware<M>>::Future

fn on_request<F, X>( &self, request: Request, meta: M, process: F, ) -> Self::Future

where F: FnOnce(Request, M) -> X + Send, X: Future<Item = Option<Response>, Error = ()> + Send + 'static,

Implementors

impl<M: Metadata> Middleware<M> for Noop

type Future = Box<dyn Future<Item = Option<Response>, Error = ()> + Send>