Struct TopicPublisherRaw 

pub struct TopicPublisherRaw { /* private fields */ }

Raw (opaque bytes) publisher from [Node::create_publisher_raw].

ZMQ mode shares one underlying bus PUB socket per node; WebSocket RPC mode issues unary Publish RPCs. Each handle remembers its topic.

Topology registration is shared across clones and unregistered when the last handle drops.

Implementations

impl TopicPublisherRaw

pub fn topic(&self) -> &str

pub fn publish(&self, payload: &[u8]) -> Result<()>

pub fn high_water_mark(&self) -> Result<HighWaterMark>

pub fn set_high_water_mark(&self, hwm: HighWaterMark) -> Result<()>

pub fn set_send_timeout_ms(&self, ms: i32) -> Result<()>

Milliseconds; 0 fails immediately when the send HWM is full (drop newest).

Trait Implementations

impl Clone for TopicPublisherRaw

fn clone(&self) -> TopicPublisherRaw

Returns a duplicate of the value.

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

Performs copy-assignment from source.