Struct RedisTestClient 

pub struct RedisTestClient { /* private fields */ }

Driver around a single RedisTestBroker instance.

RedisTestClient::start() constructs a fresh, isolated broker. Use it as the entry point in the ruststream::conformance harness and in handler integration tests.

Trait Implementations

impl Debug for RedisTestClient

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

Formats the value using the given formatter.

impl TestClient for RedisTestClient

type Broker = RedisTestBroker

The broker type this test client emulates.

type Subscriber = RedisTestSubscriber

The subscriber type opened by subscribe.

type Publisher = RedisTestPublisher

The publisher type returned by publisher.

type Error = RedisError

The error type returned by test-client operations.

async fn start() -> Result<Self, Self::Error>

Starts a fresh in-memory broker instance.

fn broker(&self) -> &Self::Broker

Returns a handle to the in-memory broker, suitable for registering with a RustStream.

async fn publish(&self, topic: &str, payload: &[u8]) -> Result<(), Self::Error>

Publishes a message to the in-memory broker as if from an external producer.

async fn subscribe( &self, topic: &str, ) -> Result<RedisTestSubscriber, Self::Error>

Opens a subscription against the in-memory broker. Used by integration tests that need to verify handler-level behaviour like ack / nack and redelivery.

async fn publisher(&self) -> Result<Self::Publisher, Self::Error>

Returns a publisher bound to the in-memory broker. Useful when the test needs to set headers or publish in a tight loop without allocating per-call closures.

async fn expect_published( &self, topic: &str, count: usize, timeout_dur: Duration, ) -> Result<Vec<RawMessage>, Self::Error>

Waits until at least count messages have been published to name, returning all observed messages. Fails after timeout.

async fn shutdown(self) -> Result<(), Self::Error>

Cleanly shuts down the in-memory broker.