pub async fn flush(&mut self) -> Result<(), Error> {
        self.write_send_chunk().await?;
        self.finish_write().await?;
        self.channel.flush().await?;
        Ok(())
    }
/// Finish sending the current block of messages, compressing them and sending them over the
/// reliable channel.
///
/// This method is cancel safe.
Finish sending the current block of messages, compressing them and sending them over the
reliable channel.

This method is cancel safe.
Finish sending the current block of messages compressing them and sending them over the reliable channel . This method is cancel safe .
pub async fn flush(&mut self) -> Result<(), Error> {
        self.write_send_chunk().await?;
        self.finish_write().await?;
        self.channel.flush().await?;
        Ok(())
    }
pub async fn flush ( & mut self ) -> Result < ( ) , Error > { self . write_send_chunk ( ) . await ? ; self . finish_write ( ) . await ? ; self . channel . flush ( ) . await ? ; Ok ( ( ) ) }
Finish sending the current block of messages, compressing them and sending them over the
reliable channel.
Finish sending the current block of messages compressing them and sending them over the reliable channel .
&mut self
&mut self