Struct QueueUpstreamHandle 

pub struct QueueUpstreamHandle { /* private fields */ }

Handle for a bidirectional queue upstream (send) stream.

Obtained from KubemqClient::queue_upstream(). Provides a non-blocking send() method for high-throughput batch publishing and a results() receiver for per-batch acknowledgements. The stream is cancelled on close() or when the handle is dropped.

Implementations

impl QueueUpstreamHandle

pub async fn send( &self, request_id: &str, msgs: Vec<QueueMessage>, ) -> Result<()>

Send a batch of messages with a request ID.

pub fn results(&mut self) -> &mut Receiver<QueueUpstreamResult>

Get a mutable reference to the results receiver.

pub fn close(&self)

Close the upstream stream.

Trait Implementations

impl Debug for QueueUpstreamHandle

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

Formats the value using the given formatter.

impl Drop for QueueUpstreamHandle

fn drop(&mut self)

Executes the destructor for this type.