Struct RedisTestPublisher 

pub struct RedisTestPublisher { /* private fields */ }

Publisher returned by crate::testing::RedisTestBroker::publisher.

Mirrors the real publisher’s transaction surface: messages published inside a transaction are buffered and only fan out on commit (in publish order), or are discarded on abort.

Trait Implementations

impl Clone for RedisTestPublisher

fn clone(&self) -> RedisTestPublisher

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RedisTestPublisher

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

Formats the value using the given formatter.

impl Publisher for RedisTestPublisher

type Error = RedisError

The error type returned by publish.

async fn publish(&self, msg: OutgoingMessage<'_>) -> Result<(), Self::Error>

Publishes a message to the broker.

impl TransactionalPublisher for RedisTestPublisher

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

Begins a new transaction on this publisher.

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

Commits the active transaction, making all buffered messages visible atomically.

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

Aborts the active transaction, discarding all buffered messages.