Struct RedisTestBroker 

pub struct RedisTestBroker { /* private fields */ }

In-process Redis broker used for handler-level tests.

publish matches stream keys exactly (Redis Streams have no wildcard subjects) and hands the message to every matching subscriber’s channel; ack/nack(requeue = false) consume the delivery and nack(requeue = true) re-sends it to the same subscriber’s queue.

Broker-specific edge cases (consumer-group cursors, XAUTOCLAIM redelivery, idle reclaim, MAXLEN trimming, dead-letter routing) are intentionally NOT simulated. Use a real Redis server for those scenarios.

Implementations

impl RedisTestBroker

pub fn new() -> Self

Constructs a fresh, isolated test broker. Equivalent to Self::default.

pub async fn subscribe( &self, key: impl Into<String>, ) -> Result<RedisTestSubscriber, RedisError>

Opens a subscription on the stream key. Mirrors the public surface of crate::RedisBroker::subscribe; in handler-stub mode only the key is used for routing (no consumer-group bookkeeping).

Errors

Returns RedisError::Subscribe when key is empty.

pub fn publisher(&self) -> RedisTestPublisher

Returns a publisher bound to this broker. Cheap to clone.

pub async fn expect_published( &self, key: &str, count: usize, timeout_dur: Duration, ) -> Vec<RawMessage>

Awaits until count messages have landed on key (or the timeout elapses) and returns the recorded prefix of the published log. Returns whatever is recorded on timeout, never blocking past it.

Trait Implementations

impl Broker for RedisTestBroker

type Error = RedisError

The error type returned by broker-level operations.

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

Establishes the connection to the broker. Idempotent: calling multiple times must not open additional sockets.

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

Closes the broker connection, flushing in-flight publishes and stopping background tasks.

impl Clone for RedisTestBroker

fn clone(&self) -> RedisTestBroker

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RedisTestBroker

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

Formats the value using the given formatter.

impl Default for RedisTestBroker

fn default() -> RedisTestBroker

Returns the “default value” for a type.

impl DescribeServer for RedisTestBroker

fn describe_server(&self) -> ServerSpec

Returns the server coordinates for this broker.

impl Subscribe for RedisTestBroker

type Subscriber = RedisTestSubscriber

The subscriber type opened by a by-name subscription.

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

Opens a subscription to name, producing this broker’s Subscriber.