Struct MockEndpointInner 

pub struct MockEndpointInner {
    pub name: String,
    /* private fields */
}

The actual data behind a mock endpoint. Shared across all MockEndpoint instances created with the same name via MockComponent.

Use get_received_exchanges and assert_exchange_count to inspect recorded exchanges in tests.

Fields

name: String

Implementations

impl MockEndpointInner

pub async fn get_received_exchanges(&self) -> Vec<Exchange>

Return a snapshot of all exchanges received so far.

pub async fn assert_exchange_count(&self, expected: usize)

Assert that exactly expected exchanges have been received.

Panics

Panics if the count does not match.

pub async fn await_exchanges(&self, count: usize, timeout: Duration)

Wait until at least count exchanges have been received, or panic on timeout.

Uses tokio::sync::Notify — no polling. Returns immediately if count exchanges are already present.

Panics

Panics if timeout elapses before count exchanges arrive.

pub fn exchange(&self, idx: usize) -> ExchangeAssert

Return an ExchangeAssert for the exchange at idx.

Panics

Panics if idx is out of bounds. Always call await_exchanges first to ensure the exchange has been received.

Panics if called from a single-threaded tokio runtime. Use #[tokio::test(flavor = "multi_thread")] for tests that call this method.