Struct ResponseStream 

pub struct ResponseStream {
    body: BoxBody<Bytes, Box<dyn Error + Send + Sync>>,
    guards: Mutex<Vec<Box<dyn Send + 'static>>>,
}

An upstream response body being relayed to the client unbuffered, plus any guards whose lifetime must match the stream rather than the node that produced it (balancer in-flight counters, limit-conn permits).

Fields

body: BoxBody<Bytes, Box<dyn Error + Send + Sync>>

guards: Mutex<Vec<Box<dyn Send + 'static>>>

Implementations

impl ResponseStream

pub fn new(body: BoxBody<Bytes, Box<dyn Error + Send + Sync>>) -> Self

pub fn hold(&mut self, guard: Box<dyn Send + 'static>)

Attaches a guard released when the stream is consumed or dropped. Production code binds guards in at construction instead (see upstream.rs’s use of body_holding); this is exercised directly by this module’s own tests.

pub fn into_parts( self, ) -> (BoxBody<Bytes, Box<dyn Error + Send + Sync>>, Vec<Box<dyn Send + 'static>>)

Takes the body for transmission. The guards travel with the returned Vec, not with self (which is consumed here) — the caller must keep that Vec alive until the returned body has finished streaming to the client; dropping it early releases the guards early.

Trait Implementations

impl Debug for ResponseStream

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

Formats the value using the given formatter.