Struct ConnectedZmqRpc 

pub struct ConnectedZmqRpc { /* private fields */ }

The connected form of ZmqRpc.

Implementations

impl ConnectedZmqRpc

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

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

pub fn publisher(&self) -> ZmqRpcPublisher

A publisher from the connected form.

Trait Implementations

impl ConnectedBroker for ConnectedZmqRpc

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 ConnectedZmqRpc

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

Formats the value using the given formatter.

impl DefaultPublish for ConnectedZmqRpc

type Policy = ZmqRpcPublish

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

impl PublishPolicy<ConnectedZmqRpc> for ZmqRpcPublish

type Live = ZmqRpcPublisher

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

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

impl Subscribe for ConnectedZmqRpc

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.