Struct RedisTestPublisher 

pub struct RedisTestPublisher { /* private fields */ }

Publisher returned by ConnectedRedisTestBroker::publisher.

Mirrors the real publisher’s transaction surface, both kinds: messages published inside a transaction are buffered and only fan out on commit (in publish order), or are discarded on abort. The borrowed kind (TransactionalPublisher) uses the handle’s single buffer; the owned kind (OwnedTransactions) hands out an independent RedisTestTransaction per call.

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 OwnedTransactions for RedisTestPublisher

Owned transactions, mirroring RedisPublisher: every call opens an independent buffer-owning RedisTestTransaction, so any number can be open concurrently and the handle keeps publishing directly meanwhile.

type Transaction = RedisTestTransaction

The buffer-owning transaction opened by transaction.

async fn transaction(&self) -> Result<RedisTestTransaction, RedisError>

Opens a new transaction owned by the returned value.

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>

Errors

Returns RedisError::TransactionBusy when a transaction is already open on this handle, leaving that one untouched.

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

Errors

Returns RedisError::NoTransaction when no transaction is open on this handle.

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

Errors

Returns RedisError::NoTransaction when no transaction is open on this handle.