fn poll_complete_tx(&self, cx: &mut Context<'_>) -> Poll<Result<()>> {
        // TODO(https://fxbug.bug/78342): The fuchsia_async fifo wrapper API only
        // allows to read one at a time, consider batch reading to reduce the
        // number of syscalls if it becomes a performance issue in the future.
        match ready!(self.tx.try_read(cx)).map_err(|status| Error::Fifo("read", "tx", status))? {
            Some(head) => Poll::Ready(self.pool.tx_completed(head)),
            None => Err(Error::PeerClosed("tx"))?,
        }
    }
/// Polls completed tx descriptors from the driver then puts them in pool.
Polls completed tx descriptors from the driver then puts them in pool.
Polls completed tx descriptors from the driver then puts them in pool .
fn poll_complete_tx(&self, cx: &mut Context<'_>) -> Poll<Result<()>> {
        // TODO(https://fxbug.bug/78342): The fuchsia_async fifo wrapper API only
        // allows to read one at a time, consider batch reading to reduce the
        // number of syscalls if it becomes a performance issue in the future.
        match ready!(self.tx.try_read(cx)).map_err(|status| Error::Fifo("read", "tx", status))? {
            Some(head) => Poll::Ready(self.pool.tx_completed(head)),
            None => Err(Error::PeerClosed("tx"))?,
        }
    }
fn poll_complete_tx ( & self , cx : & mut Context < ' _ > ) -> Poll < Result < ( ) > > { // TODO(https://fxbug.bug/78342): The fuchsia_async fifo wrapper API only // allows to read one at a time, consider batch reading to reduce the // number of syscalls if it becomes a performance issue in the future. match ready ! ( self tx try_read ( cx ) ) . map_err ( | status | Error :: Fifo ( " " , " " , status ) ) ? { Some ( head ) => Poll :: Ready ( self . pool . tx_completed ( head ) ) , None => Err ( Error :: PeerClosed ( " " ) ) ? , } }
Polls completed tx descriptors from the driver then puts them in pool.
Polls completed tx descriptors from the driver then puts them in pool .
&self
cx
&mut Context<'_>
&self
cx
&mut Context<'_>