Trait messaging_thread_pool::thread_pool_sender_and_receiver::ThreadPoolSenderAndReceiver

pub trait ThreadPoolSenderAndReceiver<P>where
    P: PoolItem,{
    fn send_and_receive<'a, const N: usize, T, U>(
        &'a self,
        requests: impl Iterator<Item = T> + 'a
    ) -> Box<dyn Iterator<Item = U> + 'a>
    where
        T: RequestMessage<N, P> + 'a,
        U: ResponseMessage<N, P> + '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, const N: usize, T, U>(
    &'a self,
    requests: impl Iterator<Item = T> + 'a
) -> Box<dyn Iterator<Item = U> + 'a>where
    T: RequestMessage<N, P> + 'a,
    U: ResponseMessage<N, P> + '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

Implementors

impl<P> ThreadPoolSenderAndReceiver<P> for ThreadPool<P>where
    P: PoolItem,

An implementation of the ThreadPoolSenderAndReceiver trait for ThreadPool

impl<P, T1, U1> ThreadPoolSenderAndReceiver<P> for ThreadPoolMock<P, T1, U1>where
    P: PoolItem + PartialEq,
    P::Api: PartialEq,
    P::Init: PartialEq,
    T1: Into<ThreadRequestResponse<P>> + Debug,
    U1: Into<ThreadRequestResponse<P>> + Debug,