Struct xaynet::services::messages::PetMessageService

pub struct PetMessageService<MessageParser, PreProcessor, StateMachine> { /* fields omitted */ }

A service that processes requests from the beginning to the end.

The processing is divided in three phases:

1. The raw request (which is just a vector of bytes represented an encrypted message) goes through the MessageParser service, which decrypt the message, validates it, and parses it

2. The message is passed to the PreProcessor, which depending on the message type performs some additional checks. The PreProcessor may also discard the message

3. Finally, the message is handled by the StateMachine service.

Implementations

impl<MP, PP, SM> PetMessageService<Service<MP, Traced<MessageParserRequest>, fn(_: &Traced<MessageParserRequest>) -> Span>, Service<PP, Traced<PreProcessorRequest>, fn(_: &Traced<PreProcessorRequest>) -> Span>, Service<SM, Traced<StateMachineRequest>, fn(_: &Traced<StateMachineRequest>) -> Span>> where
    MP: Service<Traced<MessageParserRequest>, Response = MessageParserResponse>,
    PP: Service<Traced<PreProcessorRequest>, Response = PreProcessorResponse>,
    SM: Service<Traced<StateMachineRequest>, Response = StateMachineResponse>, 

pub fn new(message_parser: MP, pre_processor: PP, state_machine: SM) -> Self

Instantiate a new PetMessageService with the given sub-services

Trait Implementations

impl<MessageParser: Clone, PreProcessor: Clone, StateMachine: Clone> Clone for PetMessageService<MessageParser, PreProcessor, StateMachine>

fn clone(&self) -> PetMessageService<MessageParser, PreProcessor, StateMachine>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<MP, PP, SM> Service<Traced<MessageParserRequest>> for PetMessageService<MP, PP, SM> where
    MP: Service<Traced<MessageParserRequest>, Response = MessageParserResponse> + Clone + Send + 'static,
    <MP as Service<Traced<MessageParserRequest>>>::Future: Send + 'static,
    <MP as Service<Traced<MessageParserRequest>>>::Error: Into<Box<dyn Error + Sync + Send + 'static>>, 

type Response = MessageParserResponse

Responses given by the service.

type Error = Box<dyn Error + Send + Sync + 'static>

Errors produced by the service.

type Future = Pin<Box<dyn Future<Output = Result<Self::Response, Self::Error>> + Send + 'static>>

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

Process the request and return the response asynchronously.

impl<MP, PP, SM> Service<Traced<PreProcessorRequest>> for PetMessageService<MP, PP, SM> where
    PP: Service<Traced<PreProcessorRequest>, Response = PreProcessorResponse> + Clone + Send + 'static,
    <PP as Service<Traced<PreProcessorRequest>>>::Future: Send + 'static,
    <PP as Service<Traced<PreProcessorRequest>>>::Error: Into<Box<dyn Error + Send + Sync + 'static>>, 

type Response = PreProcessorResponse

Responses given by the service.

type Error = Box<dyn Error + Send + Sync + 'static>

Errors produced by the service.

type Future = Pin<Box<dyn Future<Output = Result<Self::Response, Self::Error>> + Send + 'static>>

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

Process the request and return the response asynchronously.

impl<MP, PP, SM> Service<Traced<StateMachineRequest>> for PetMessageService<MP, PP, SM> where
    SM: Service<Traced<StateMachineRequest>, Response = StateMachineResponse> + Clone + Send + 'static,
    <SM as Service<Traced<StateMachineRequest>>>::Future: Send + 'static,
    <SM as Service<Traced<StateMachineRequest>>>::Error: Into<Box<dyn Error + Send + Sync + 'static>>, 

type Response = StateMachineResponse

Responses given by the service.

type Error = Box<dyn Error + Send + Sync + 'static>

Errors produced by the service.

type Future = Pin<Box<dyn Future<Output = Result<Self::Response, Self::Error>> + Send + 'static>>

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

Process the request and return the response asynchronously.