async fn send_queued(&mut self) -> Result<(), zx::Status> {
        let bytes = std::mem::take(&mut self.buffer);
        let result = self.channel.write_all(&bytes).await;
        if let Ok(_) = result {
            debug!("Sent {:?}", String::from_utf8_lossy(&bytes));
        }
        self.buffer_cursor = 0;
        self.needs_flush = false;
        Ok(result?)
    }
/// Write all queued data to the `channel` - returns Error if writing fails.
Write all queued data to the `channel` - returns Error if writing fails.
Write all queued data to the ` channel ` - returns Error if writing fails .
async fn send_queued(&mut self) -> Result<(), zx::Status> {
        let bytes = std::mem::take(&mut self.buffer);
        let result = self.channel.write_all(&bytes).await;
        if let Ok(_) = result {
            debug!("Sent {:?}", String::from_utf8_lossy(&bytes));
        }
        self.buffer_cursor = 0;
        self.needs_flush = false;
        Ok(result?)
    }
async fn send_queued ( & mut self ) -> Result < ( ) , zx :: Status > { let bytes = std :: mem :: take ( & mut self . buffer ) ; let result = self . channel . write_all ( & bytes ) . await ; if let Ok ( _ ) = result { debug ! ( " " String from_utf8_lossy ( bytes ) ) ; } self . buffer_cursor = 0 ; self . needs_flush = false ; Ok ( result ? ) }
Write all queued data to the `channel` - returns Error if writing fails.
Write all queued data to the ` channel ` - returns Error if writing fails .
&mut self
&mut self