Trait messaging_thread_pool::SenderAndReceiver

pub trait SenderAndReceiver<P>
where
    P: PoolItem,
{
    // Required method
    fn send_and_receive<'a, T>(
        &'a self,
        requests: impl Iterator<Item = T> + 'a
    ) -> Result<Box<dyn Iterator<Item = T::Response> + 'a>, SendError<SenderCouplet<P>>>
       where T: RequestWithResponse<P> + IdTargeted + 'a;

    // Provided method
    fn send_and_receive_one<'a, T>(
        &'a self,
        request: T
    ) -> Result<T::Response, SendError<SenderCouplet<P>>>
       where T: RequestWithResponse<P> + IdTargeted + 'a { ... }
}

This trait allows a consumer to use a trait instead of the concrete implementation of thread pool.\ Unfortunately the send_and_receive are not a precise match for corresponding function in crate::ThreadPool itself. This is because of the limitation of the trait return types (it has to return a boxed iterator)

Required Methods

fn send_and_receive<'a, T>( &'a self, requests: impl Iterator<Item = T> + 'a ) -> Result<Box<dyn Iterator<Item = T::Response> + 'a>, SendError<SenderCouplet<P>>>

where T: RequestWithResponse<P> + IdTargeted + 'a,

This function sends a request to a worker thread and receives a response back

The request is received as a vec and the responses are received back in a vec

Provided Methods

fn send_and_receive_one<'a, T>( &'a self, request: T ) -> Result<T::Response, SendError<SenderCouplet<P>>>

where T: RequestWithResponse<P> + IdTargeted + 'a,

a default convenience function for dealing with the case when there is specifically only one message to send and (therefore) only one response to receive

Object Safety

This trait is not object safe.

Implementors

impl<P> SenderAndReceiver<P> for SenderAndReceiverRawMock<P>

where P: PoolItem + PartialEq, P::Api: PartialEq, P::Init: PartialEq,

impl<P> SenderAndReceiver<P> for ThreadPool<P>

where P: PoolItem,

An implementation of the [ThreadPoolSenderAndReceiver] trait for ThreadPool

impl<P, T1> SenderAndReceiver<P> for SenderAndReceiverMock<P, T1>

where P: PoolItem + PartialEq, P::Api: PartialEq, P::Init: PartialEq, T1: RequestWithResponse<P>,