Struct ZmqRpc 

pub struct ZmqRpc { /* private fields */ }

The DEALER/ROUTER request-reply pattern.

Examples

use ruststream_zeromq::{ZmqEndpoint, ZmqRpc};

let responder = ZmqRpc::new(ZmqEndpoint::bind("tcp://0.0.0.0:5557"));
let requester = ZmqRpc::new(ZmqEndpoint::connect("tcp://ml:5557"));

Implementations

impl ZmqRpc

pub fn new(endpoint: ZmqEndpoint) -> Self

Records the endpoint. No I/O.

pub fn publisher(&self) -> ZmqRpcPublisher

A publisher sharing this pattern’s state; buildable before connect.

Trait Implementations

impl Broker for ZmqRpc

type Error = ZmqError

The error type returned by broker-level operations.

type Connected = ConnectedZmqRpc

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 ZmqRpc

fn clone(&self) -> ZmqRpc

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ZmqRpc

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

Formats the value using the given formatter.

impl DescribeServer for ZmqRpc

fn describe_server(&self) -> ServerSpec

Returns the server coordinates for this broker.