Struct FrameSink 

pub struct FrameSink { /* private fields */ }

Cheaply cloneable handle to one connection’s bounded outbound frame queue.

Backends emit responses, streaming frames, and future PUSH frames through this single path. The queue is bounded twice: by queued BYTES (the budget that matters for memory and for how long a slow reader may pause), and by the mpsc channel’s frame count (a backstop). The socket layer owns the sole receiver/writer.

Implementations

impl FrameSink

pub fn new(tx: Sender<OutboundFrame>) -> Self

A sink with the standard per-connection byte budget (crate::server::CONNECTION_EGRESS_BYTE_BUDGET); the frame-count bound is whatever capacity tx’s channel was created with.

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

Trait Implementations

impl Clone for FrameSink

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for FrameSink

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

Formats the value using the given formatter.