Struct RedisDefaultPublisher 

pub struct RedisDefaultPublisher { /* private fields */ }

The live form of RedisDefaultPublish: writes each name the way this connection’s subscriptions read it. Cheap to clone.

Obtain it from ConnectedRedisBroker::default_publisher or by pairing the policy. Like every publisher here it may outlive the connection, so publishing after shutdown reports RedisError::ShutDown.

Trait Implementations

impl Clone for RedisDefaultPublisher

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RedisDefaultPublisher

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

Formats the value using the given formatter.

impl Publisher for RedisDefaultPublisher

type Payload = Take

As on RedisPublisher: a name nothing reads is a stream, whose XADD keeps the body.

type Options = RedisPublishOptions

The options every publisher of this crate takes, so a partition key resolves the same whichever family the name is written in.

type Error = RedisError

The error type returned by publish.

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

Publishes a message to the broker, with the per-message settings the call site adjusted.

fn base_headers(&self) -> Option<&HeaderMap>

The headers this publisher contributes to every message it sends, underneath whatever the message itself names.