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.

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.

impl SubscriptionSource<RedisTestBroker> for RedisList

Available on crate feature testing only.

type Subscriber = RedisTestSubscriber

The subscriber type this source opens.

fn name(&self) -> &str

The name (subject / channel) this subscription binds to.

async fn subscribe( self, broker: &RedisTestBroker, ) -> Result<Self::Subscriber, RedisError>

Opens the subscription against broker. Called once, after Broker::connect.

impl SubscriptionSource<RedisTestBroker> for RedisPubSub

Available on crate feature testing only.

type Subscriber = RedisTestSubscriber

The subscriber type this source opens.

fn name(&self) -> &str

The name (subject / channel) this subscription binds to.

async fn subscribe( self, broker: &RedisTestBroker, ) -> Result<Self::Subscriber, RedisError>

Opens the subscription against broker. Called once, after Broker::connect.

impl SubscriptionSource<RedisTestBroker> for RedisStream

Available on crate feature testing only.

type Subscriber = RedisTestSubscriber

The subscriber type this source opens.

fn name(&self) -> &str

The name (subject / channel) this subscription binds to.

async fn subscribe( self, broker: &RedisTestBroker, ) -> Result<Self::Subscriber, RedisError>

Opens the subscription against broker. Called once, after Broker::connect.

impl TestableBroker for RedisTestBroker

fn install_coordinator(&self, coordinator: Coordinator)

Installs the harness coordinator into this broker’s bus for a test run. Idempotent: a second install on the same broker is ignored.

fn inject(&self, message: OutgoingMessage<'_>)

Injects a message onto the bus as an external producer would, synchronously (no awaiting). Routes through the broker’s normal fanout, so it is recorded and counted like any publish.

fn published(&self, name: &str) -> Vec<RawMessage>

Returns every message published to name on this broker, in publish order. Backs the harness’s published::<T>(name) assertions and expect_published.