pub async fn send_data(&mut self, chunk: Bytes) -> crate::Result<()> {
        futures_util::future::poll_fn(|cx| self.poll_ready(cx)).await?;
        self.tx
            .try_send(Ok(chunk))
            .map_err(|_| crate::Error::new_closed())
    }
/// Send data on this channel when it is ready.
Send data on this channel when it is ready.
Send data on this channel when it is ready .
pub async fn send_data(&mut self, chunk: Bytes) -> crate::Result<()> {
        futures_util::future::poll_fn(|cx| self.poll_ready(cx)).await?;
        self.tx
            .try_send(Ok(chunk))
            .map_err(|_| crate::Error::new_closed())
    }
pub async fn send_data ( & mut self , chunk : Bytes ) -> crate :: Result < ( ) > { futures_util :: future :: poll_fn ( | cx | self . poll_ready ( cx ) ) . await ? ; self . tx . try_send ( Ok ( chunk ) ) . map_err ( | _ | crate :: Error :: new_closed ( ) ) }
Send data on this channel when it is ready.
Send data on this channel when it is ready .
&mut self
chunk
Bytes
&mut self
chunk
Bytes