Struct ZmqFanout 

pub struct ZmqFanout { /* private fields */ }

The PUB/SUB fan-out: each message reaches every subscriber whose name prefix matches.

Examples

use ruststream_zeromq::{ZmqEndpoint, ZmqFanout};

let publisher_side = ZmqFanout::new(ZmqEndpoint::bind("tcp://0.0.0.0:5556"));
let subscriber_side = ZmqFanout::new(ZmqEndpoint::connect("tcp://events:5556"));

Implementations

impl ZmqFanout

pub fn new(endpoint: ZmqEndpoint) -> Self

Records the endpoint. No I/O.

pub fn publisher(&self) -> ZmqFanoutPublisher

A publisher sharing this fan-out’s state; buildable before connect.

Trait Implementations

impl Broker for ZmqFanout

type Error = ZmqError

The error type returned by broker-level operations.

type Connected = ConnectedZmqFanout

The connected form of this broker: the typed witness that connect succeeded.

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

Establishes the connection to the broker, consuming the unconnected form.

fn bindable(self) -> Bindable<Self>

where Self: 'static,

Wraps the broker for publisher-token minting before registration: the returned Bindable hands out Bound tokens via its bind, and is itself what with_broker takes.

impl Clone for ZmqFanout

fn clone(&self) -> ZmqFanout

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ZmqFanout

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

Formats the value using the given formatter.

impl DescribeServer for ZmqFanout

fn describe_server(&self) -> ServerSpec

Returns the server coordinates for this broker.