Struct BodySender 

pub struct BodySender { /* private fields */ }

Sends body chunks of a streaming response; clone it to feed one stream from several tasks. The body ends when all clones are dropped.

Implementations

impl BodySender

pub async fn send(&self, chunk: impl Into<Bytes>) -> Result<(), Disconnected>

Queue a chunk; waits while the client is slower than the producer (the channel is bounded), fails once the client is gone.

pub fn is_closed(&self) -> bool

True once the client has gone away

pub async fn closed(&self)

Completes when the client has gone away, e.g. to stop a producer that is waiting for its next event

Trait Implementations

impl Clone for BodySender

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.