Struct MockTransport

pub struct MockTransport { /* private fields */ }

A transport that returns responses from an associated Asserter.

See the module documentation.

Implementations

impl MockTransport

pub const fn new(asserter: Asserter) -> Self

Create a new MockTransport with the given Asserter.

pub const fn asserter(&self) -> &Asserter

Return a reference to the associated Asserter.

Methods from Deref<Target = Asserter>

pub fn push(&self, response: MockResponse)

Push a response into the queue.

pub fn push_success<R: Serialize>(&self, response: &R)

Insert a successful response into the queue.

Panics

Panics if serialization fails.

pub fn push_failure(&self, error: ErrorPayload)

Push an error payload into the queue.

pub fn push_failure_msg(&self, msg: impl Into<Cow<'static, str>>)

Push an internal error message into the queue.

pub fn pop_response(&self) -> Option<MockResponse>

Pops the next mock response.

pub fn read_q(&self) -> impl Deref<Target = VecDeque<MockResponse>> + '_

Returns a read lock guard to the responses queue.

pub fn write_q(&self) -> impl DerefMut<Target = VecDeque<MockResponse>> + '_

Returns a write lock guard to the responses queue.

Trait Implementations

impl Clone for MockTransport

fn clone(&self) -> MockTransport

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for MockTransport

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

Formats the value using the given formatter.

impl Deref for MockTransport

type Target = Asserter

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.

impl Service<RequestPacket> for MockTransport

type Response = ResponsePacket

Responses given by the service.

type Error = RpcError<TransportErrorKind>

Errors produced by the service.

type Future = Pin<Box<dyn Future<Output = Result<ResponsePacket, RpcError<TransportErrorKind>>> + Send>>

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

Process the request and return the response asynchronously.