Struct ConnectedZmqFanout 

pub struct ConnectedZmqFanout { /* private fields */ }

The connected form of ZmqFanout.

Implementations

impl ConnectedZmqFanout

pub fn bound_address(&self) -> Option<String>

The address a local subscription resolved by binding (useful with an ephemeral tcp://...:0 endpoint); None until a subscription has bound.

pub fn publisher(&self) -> ZmqFanoutPublisher

A publisher from the connected form.

Trait Implementations

impl ConnectedBroker for ConnectedZmqFanout

type Error = ZmqError

The error type returned by connected-broker operations.

type Closed = ()

The terminal witness returned by shutdown.

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

Closes the broker connection, flushing in-flight publishes and stopping background tasks, consuming the connected form.

impl Debug for ConnectedZmqFanout

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

Formats the value using the given formatter.

impl DefaultPublish for ConnectedZmqFanout

type Policy = ZmqFanoutPublish

The broker’s plain publish policy, constructible with its defaults.

impl PublishPolicy<ConnectedZmqFanout> for ZmqFanoutPublish

type Live = ZmqFanoutPublisher

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: &ConnectedZmqFanout, ) -> Result<Self::Live, PairError>

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

impl Subscribe for ConnectedZmqFanout

type Subscriber = ZmqSubscriber

The subscriber type opened by a by-name subscription.

async fn subscribe(&self, name: &str) -> Result<Self::Subscriber, Self::Error>

Opens a subscription to name, producing this broker’s Subscriber.