Struct ResponseSender 

pub struct ResponseSender { /* private fields */ }

Encode Message into Bytes and send it to ResponseStream.

Implementations

impl ResponseSender

pub fn downgrade(&self) -> ResponseWeakSender

downgrade Self to a weak sender.

pub async fn text(&self, txt: impl Into<Bytes>) -> Result<(), ProtocolError>

encode Message::Text variant and add to ResponseStream.

pub fn binary( &self, bin: impl Into<Bytes>, ) -> impl Future<Output = Result<(), ProtocolError>> + '_

encode Message::Binary variant and add to ResponseStream.

pub fn continuation( &self, item: Item, ) -> impl Future<Output = Result<(), ProtocolError>> + '_

encode Message::Continuation variant and add to ResponseStream.

pub fn ping( &self, bin: impl Into<Bytes>, ) -> impl Future<Output = Result<(), ProtocolError>> + '_

encode Message::Ping variant and add to ResponseStream.

pub fn pong( &self, bin: impl Into<Bytes>, ) -> impl Future<Output = Result<(), ProtocolError>> + '_

encode Message::Pong variant and add to ResponseStream.

pub async fn close( &mut self, reason: Option<impl Into<CloseReason>>, ) -> Result<(), ProtocolError>

encode Message::Close variant and add to ResponseStream.

This method can only be executed once. Concurrent callers would race for executing and at most one would succeed. Other callers failing the race would observe ProtocolError::SendClosed

Trait Implementations

impl Debug for ResponseSender

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

Formats the value using the given formatter.