Struct WriterHandle 

pub struct WriterHandle { /* private fields */ }

Handle for sending frames to the writer task.

This is cheaply cloneable and can be shared across multiple handlers.

Implementations

impl WriterHandle

pub async fn send(&self, frame: OutboundFrame) -> Result<()>

Send a frame to the writer task.

This method will wait if backpressure is active, timing out after the configured duration.

pub fn is_backpressure_active(&self) -> bool

Check if backpressure is currently active.

pub fn pending_count(&self) -> usize

Get current pending frame count.

pub fn try_send(&self, frame: OutboundFrame) -> Result<()>

Try to send a frame without waiting for backpressure.

Returns Err(BackpressureTimeout) immediately if at capacity.

Trait Implementations

impl Clone for WriterHandle

fn clone(&self) -> WriterHandle

Returns a duplicate of the value.

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

Performs copy-assignment from source.