Commits on Oct 8, 2020

1. Impl poll_readable and poll_writable. …

   ```rust
   pub struct ListenStream {
       listener: Async<TcpListener>,
   }
   
   impl Stream for ListenStream {
       type Item = Result<Async<TcpStream>, std::io::Error>;
   
       fn poll_next(mut self: Pin<&mut Self>, cx: &mut Context) -> Poll<Option<Self::Item>> {
           loop {
               match self.listener.accept().now_or_never() {
                   Some(Ok((stream, _))) => {
                       return Poll::Ready(Some(Ok(stream)));
                   }
                   Some(Err(err)) => {
                       return Poll::Ready(Some(Err(err)));
                   }
                   None => {
                       match self.listener.poll_readable(cx) {
                           Poll::Ready(Ok(())) => continue,
                           Poll::Pending => return Poll::Pending,
                           Poll::Ready(Err(err)) => return Poll::Ready(Some(Err(err))),
                       }
                   }
               }
           }
       }
   }
   ```

   

   dvc94ch committed Oct 8, 2020
   Configuration menu

   • View commit details
   • Copy full SHA for ca54598
   • Browse repository at this point

   Copy the full SHA

   ca54598 View commit details

   Browse the repository at this point in the history