Module testing 

In-process Redis test transport used by application unit tests and the conformance suite.

Gated by the testing cargo feature. The broker is a synchronous dispatcher: publish fans the message out to every subscriber whose stream key matches exactly. Public surface:

• RedisTestBroker - the unconnected form, a Broker + DescribeServer built synchronously like the real one;
• ConnectedRedisTestBroker - its connected form, backed by an in-process key router, which implements Subscribe and ruststream::testing::TestableBroker so it plugs straight into the TestApp harness and the framework’s conformance suite;
• RedisTestPublish / RedisTestPublisher - the publish policy and the live publisher it pairs into, carrying both transaction kinds (RedisTestTransaction is the owned one);
• RedisTestSubscriber / RedisTestMessage - Subscriber and IncomingMessage impls with nack(requeue = true) redelivery (re-sent into the same subscriber’s queue).

No redis-server, no docker, no network. Broker-specific edge cases (consumer-group cursors, XAUTOCLAIM redelivery, idle reclaim, MAXLEN trimming, dead-letter routing) are out of scope here. Exercise them against a real Redis server.

Structs

ConnectedRedisTestBroker

The connected form of RedisTestBroker: what the harness and the conformance suite drive.

RedisTestBroker

In-process stand-in for RedisBroker, used for handler-level tests.

RedisTestMessage

Message handed to handlers from a RedisTestSubscriber.

RedisTestPublish

The publish policy of the in-process broker, mirroring RedisPublish.

RedisTestPublisher

Publisher returned by ConnectedRedisTestBroker::publisher.

RedisTestSubscriber

Subscriber returned by crate::testing::ConnectedRedisTestBroker::subscribe.

RedisTestTransaction

An owned in-process transaction, opened by transaction on a RedisTestPublisher.