Struct OnMessageCreated

pub struct OnMessageCreated<Service, Fallback, Req> { /* private fields */ }

Available on crate feature tower only.

MessageCreatedPayloadをhandleするServiceです。

Trait Implementations

impl<Service: Clone, Fallback: Clone, Req: Clone> Clone for OnMessageCreated<Service, Fallback, Req>

fn clone(&self) -> OnMessageCreated<Service, Fallback, Req>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<Service: Debug, Fallback: Debug, Req: Debug> Debug for OnMessageCreated<Service, Fallback, Req>

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

Formats the value using the given formatter.

impl<State, Service, Fallback> Service<(State, Event)> for OnMessageCreated<Service, Fallback, (State, MessageCreatedPayload)>

where Service: Service<(State, MessageCreatedPayload), Response = ()>, Service::Error: Into<Box<dyn Error + Send + Sync + 'static>>, Fallback: Service<(State, Event), Response = (), Error = Error>,

type Response = ()

Responses given by the service.

type Error = Error

Errors produced by the service.

type Future = Either<WrapErrorFuture<<Service as Service<(State, MessageCreatedPayload)>>::Future, <Service as Service<(State, MessageCreatedPayload)>>::Error>, <Fallback as Service<(State, Event)>>::Future>

The future response value.

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: (State, Event)) -> Self::Future

Process the request and return the response asynchronously.

impl<State, Service, Fallback> Service<(State, Event)> for OnMessageCreated<Service, Fallback, MessageCreatedPayload>

where Service: Service<MessageCreatedPayload, Response = ()>, Service::Error: Into<Box<dyn Error + Send + Sync + 'static>>, Fallback: Service<(State, Event), Response = (), Error = Error>,

type Response = ()

Responses given by the service.

type Error = Error

Errors produced by the service.

type Future = Either<WrapErrorFuture<<Service as Service<MessageCreatedPayload>>::Future, <Service as Service<MessageCreatedPayload>>::Error>, <Fallback as Service<(State, Event)>>::Future>

The future response value.

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: (State, Event)) -> Self::Future

Process the request and return the response asynchronously.

impl<Service, Fallback> Service<Event> for OnMessageCreated<Service, Fallback, MessageCreatedPayload>

where Service: Service<MessageCreatedPayload, Response = ()>, Service::Error: Into<Box<dyn Error + Send + Sync + 'static>>, Fallback: Service<Event, Response = (), Error = Error>,

type Response = ()

Responses given by the service.

type Error = Error

Errors produced by the service.

type Future = Either<WrapErrorFuture<<Service as Service<MessageCreatedPayload>>::Future, <Service as Service<MessageCreatedPayload>>::Error>, <Fallback as Service<Event>>::Future>

The future response value.

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: Event) -> Self::Future

Process the request and return the response asynchronously.