Struct Handler 

pub struct Handler<Client> { /* private fields */ }

Implementations

impl<Client> Handler<Client>

pub fn new<H, Args>(handler_fn: H) -> Self

where H: HandlerFn<Args>, Args: Extractor<Client> + Send, Args::Error: Send, Client: Send + Sync + 'static,

pub fn new_service<S, Args>(service: S) -> Self

where S: Service<Args> + Clone + Send + Sync + 'static, S::Response: Into<EventReturn>, S::Error: Into<Error> + Send, S::Future: Send, Args: Extractor<Client> + Send, Args::Error: Send, Client: Send + Sync + 'static,

pub fn filter(self, val: impl Filter<Client>) -> Self

where Client: Send + Sync + 'static,

impl<Client> Handler<Client>

where Client: Send + Sync,

pub async fn check( &mut self, request: Request<Client>, ) -> Result<(bool, Request<Client>), (EventErrorKind, Request<Client>)>

Check if the handler pass the filters. If the handler pass all them, it will be called.

Errors

If any filter returns error, it will be wrapped into FilterError and returned together with the request

Trait Implementations

impl<Client> Clone for Handler<Client>

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<Client> Service<Request<Client>> for Handler<Client>

type Error = Error

Errors produced by the service.

type Future = Pin<Box<dyn Future<Output = Result<<Handler<Client> as Service<Request<Client>>>::Response, <Handler<Client> as Service<Request<Client>>>::Error>> + Send>>

The future response value.

type Response = Response<Client>

Responses given by the service.

fn poll_ready(&mut self, _cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>>

Returns Poll::Ready(Ok(())) when the service is able to process requests.

fn call(&mut self, req: Request<Client>) -> Self::Future

Process the request and return the response asynchronously.