Struct HostCallbackQueue 

pub struct HostCallbackQueue { /* private fields */ }

Cloneable handle host callbacks use to enqueue packets into a stream.

Wraps a push StreamValue and enforces that every enqueued packet matches the device media. The handle is cheap to clone and callbacks enqueue through non-blocking calls.

Implementations

impl HostCallbackQueue

pub fn new(stream: Arc<StreamValue>) -> Self

Wraps a push stream, capturing its media for callback validation.

pub fn stream(&self) -> Arc<StreamValue>

Returns a shared handle to the underlying stream value.

pub fn callback_packet(&self, packet: StreamPacket) -> Result<PushResult>

Enqueues a packet from a host callback after checking its media.

pub fn callback_item(&self, item: StreamItem) -> Result<PushResult>

Enqueues a prebuilt stream item from a host callback after checking its media.

pub fn drain(&self, limit: usize) -> Result<Vec<StreamItem>>

Removes up to limit buffered items from the stream.

pub fn close(&self) -> Result<()>

Closes the push side of the stream.

pub fn cancel(&self) -> Result<()>

Cancels the stream and drops buffered packets.

pub fn stats(&self) -> Result<StreamStats>

Returns the current stream statistics.

pub fn inspector( &self, route: Symbol, profile: &TransportProfile, recent_diagnostics: Vec<Symbol>, ) -> Result<StreamInspectorSnapshot>

Builds an inspector snapshot for the stream on the given route and transport profile.

Trait Implementations

impl Clone for HostCallbackQueue

fn clone(&self) -> HostCallbackQueue

Returns a duplicate of the value.

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

Performs copy-assignment from source.