Trait messaging_thread_pool::RequestWithResponse

pub trait RequestWithResponse<P>: Debug + Into<ThreadRequestResponse<P>>where
    P: PoolItem,
    Self::Response: Debug + From<ThreadRequestResponse<P>> + Into<ThreadRequestResponse<P>>,{
    type Response;
}

Expand description

This trait allows for the pairing of requests and responses

Implementing this trait for the apis request/response pairs allows the messaging infrastructure to guarantee the correctness of the messages sent and received by leveraging the type system.

Required Associated Types§

type Response

Object Safety§

This trait is not object safe.

Implementors§

impl RequestWithResponse<Randoms> for PanicRequest

ties together the request with a response

type Response = PanicResponse

impl RequestWithResponse<Randoms> for MeanRequest

ties together the request with a response

type Response = MeanResponse

impl RequestWithResponse<Randoms> for RandomsAddRequest

type Response = AddResponse

impl RequestWithResponse<Randoms> for SumRequest

ties together the request with a response

type Response = SumResponse

impl<P> RequestWithResponse<RandomsBatch<P>> for RandomsBatchAddRequest<P>
where P: SenderAndReceiver<Randoms> + Send + Sync + Debug,

type Response = AddResponse

impl<P> RequestWithResponse<RandomsBatch<P>> for SumOfSumsRequest
where P: SenderAndReceiver<Randoms> + Send + Debug + Sync,

ties together the request with a response

type Response = SumOfSumsResponse

impl<P> RequestWithResponse<P> for ThreadRequestResponse<P>
where P: PoolItem,

A ThreadRequestResponse is always a RequestWithResponse

type Response = ThreadRequestResponse<P>

impl<P> RequestWithResponse<P> for RemovePoolItemRequest
where P: PoolItem,

type Response = RemovePoolItemResponse

impl<P> RequestWithResponse<P> for ThreadAbortRequest
where P: PoolItem,

type Response = ThreadAbortResponse

impl<P> RequestWithResponse<P> for ThreadEchoRequest
where P: PoolItem,

type Response = ThreadEchoResponse

impl<P> RequestWithResponse<P> for ThreadShutdownRequest
where P: PoolItem,

type Response = ThreadShutdownResponse