Struct RedisPublish 

pub struct RedisPublish;

The declaration half of the stream publisher: pure policy, constructible anywhere.

XADD needs no options beyond the target key, which travels on each message, so the policy is a unit marker. It pairs into a RedisPublisher against a ConnectedRedisBroker, which is what makes “publishing before connect” unrepresentable.

Examples

use ruststream::{Broker, PublishPolicy};
use ruststream_fred::{RedisBroker, RedisPublish};

let policy = RedisPublish; // no connection in sight
let connected = RedisBroker::standalone("redis://localhost:6379").connect().await?;
let publisher = policy.pair(&connected).await?;

Trait Implementations

impl Clone for RedisPublish

fn clone(&self) -> RedisPublish

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for RedisPublish

impl Debug for RedisPublish

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

Formats the value using the given formatter.

impl Default for RedisPublish

fn default() -> RedisPublish

Returns the “default value” for a type.

impl Eq for RedisPublish

impl PartialEq for RedisPublish

fn eq(&self, other: &RedisPublish) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl PublishPolicy<ConnectedRedisBroker> for RedisPublish

type Live = RedisPublisher

The live form this policy pairs into: a Publisher for a leaf policy, or the live wiring form for a combinator stack (a typed publisher over a policy pairs into the same typed publisher over the live leaf).

async fn pair( self, connected: &ConnectedRedisBroker, ) -> Result<Self::Live, PairError>

Pairs the policy with a connected broker, producing the live publisher.

impl StructuralPartialEq for RedisPublish