Struct messaging_thread_pool::SenderAndReceiverMock

pub struct SenderAndReceiverMock<P, T>
where
    P: PoolItem,
    T: RequestWithResponse<P>,
{ /* private fields */ }

This structure enables the mocking of a crate::ThreadPool

It has two constructors. One takes a vec of responses that are to be returned when send_and_receive is called, the other defines the requests that are expected to be received as well as an array of responses that are to be returned.

The implementation of send_and_receive asserts that the requests are as expected if requests are provided. If no requests are provided any requests passed in are ignored and the defined set of responses are returned

Implementations

impl<P, T> SenderAndReceiverMock<P, T>

where P: PoolItem, T: RequestWithResponse<P>,

pub fn new_with_expected_requests( expected_requests: Vec<T>, returned_responses: Vec<T::Response> ) -> Self

pub fn new(returned_responses: Vec<T::Response>) -> Self

pub fn was_called(&self) -> bool

Verify that the mock send_and_receive was called at least once

pub fn is_complete(&self) -> bool

Verify that all of the responses have been returned

pub fn assert_is_complete(&self)

Assert that all of the responses have been returned; provides

Trait Implementations

impl<P, T> Debug for SenderAndReceiverMock<P, T>

where P: PoolItem + Debug, T: RequestWithResponse<P> + Debug, T::Response: Debug,

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

Formats the value using the given formatter.

impl<P, T> Default for SenderAndReceiverMock<P, T>

where P: PoolItem + Default, T: RequestWithResponse<P> + Default, T::Response: Default,

fn default() -> SenderAndReceiverMock<P, T>

Returns the “default value” for a type.

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

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

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> + 'a,

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

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