Struct PubSocket 

pub struct PubSocket { /* private fields */ }

A PUB socket for broadcasting messages to multiple subscribers.

PubSocket uses a worker pool architecture to handle multiple subscribers efficiently:

• Multiple OS threads (default: CPU core count)
• Each worker runs its own compio runtime with io_uring
• Round-robin subscriber distribution across workers
• Zero-copy message broadcasting via Arc<Bytes>
• Lock-free subscription management

Example

use monocoque::zmq::PubSocket;
use bytes::Bytes;

let mut socket = PubSocket::bind("127.0.0.1:5555").await?;

// Accept subscribers (non-blocking with worker pool)
socket.accept_subscriber().await?;

// Broadcast to all subscribers
socket.send(vec![Bytes::from("topic"), Bytes::from("data")]).await?;

Implementations

impl PubSocket

pub async fn bind(addr: impl ToSocketAddrs) -> Result<Self>

Bind to an address with default worker count (CPU cores).

pub async fn bind_with_workers( addr: impl ToSocketAddrs, worker_count: usize, ) -> Result<Self>

Bind with a specific number of worker threads.

pub async fn accept_subscriber(&mut self) -> Result<u64>

Accept a new subscriber connection.

Performs ZMTP handshake and assigns the subscriber to a worker thread. Returns the subscriber ID.

pub async fn send(&mut self, msg: Vec<Bytes>) -> Result<()>

Broadcast a multipart message to all matching subscribers.

Messages are distributed to all workers in parallel. The first frame is typically used as a topic for subscription filtering.

pub async fn send_frames(&mut self, frames: &[Bytes]) -> Result<()>

Broadcast a message given as borrowed frames.

Allocation-light counterpart to send: the shared message is allocated only when it matches a subscription, so publishing from a stack array (send_frames(&[topic, payload])) pays no per-message heap allocation on the common drop path of a topic-filtered stream.

pub const fn subscriber_count(&self) -> usize

Get the number of active subscribers.

pub fn local_addr(&self) -> Result<SocketAddr>

Get the local address this socket is bound to.

pub const fn socket_type() -> SocketType

Get the socket type.

ZeroMQ Compatibility

Corresponds to ZMQ_TYPE (16) option.

pub fn monitor(&mut self) -> SocketMonitor

Enable monitoring for this socket.

Returns a receiver for socket lifecycle events.

pub fn options_mut(&mut self) -> &mut SocketOptions

Get a mutable reference to this socket’s options.

pub fn drop_count(&self) -> u64

Number of messages dropped due to HWM backpressure.