152 use std::task::{Context, Poll, Waker};
416                     fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> {  in run()
419                             Poll::Ready(_) => return Poll::Ready(this.write.cancel()),  in run()
420                             Poll::Pending => {}  in run()
423                             Poll::Ready(Ok(())) => Poll::Ready(FutureWriteCancel::AlreadySent),  in run()
424                             Poll::Ready(Err(val)) => {  in run()
425                                 Poll::Ready(FutureWriteCancel::Dropped(val.value))  in run()
427                             Poll::Pending => Poll::Pending,  in run()
470                     fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> {  in run()
473                             Poll::Ready(_) => return Poll::Ready(this.read.cancel()),  in run()
474                             Poll::Pending => {}  in run()
477                             Poll::Ready(i) => Poll::Ready(Ok(i)),  in run()
478                             Poll::Pending => Poll::Pending,  in run()
665                     fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> {  in run()
668                             Poll::Ready(_) => this.write.cancel(),  in run()
669                             Poll::Pending => match this.write.poll(cx) {  in run()
670                                 Poll::Ready(result) => result,  in run()
671                                 Poll::Pending => return Poll::Pending,  in run()
674                         Poll::Ready((result, buffer.into_vec()))  in run()
722                     fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> {  in run()
725                             Poll::Ready(_) => this.read.cancel(),  in run()
726                             Poll::Pending => match this.read.poll(cx) {  in run()
727                                 Poll::Ready(result) => result,  in run()
728                                 Poll::Pending => return Poll::Pending,  in run()
731                         Poll::Ready((result, buffer))  in run()
838         Poll::Ready(i) => i,  in assert_ready()
839         Poll::Pending => panic!("future was pending"),  in assert_ready()
846         Poll::Ready(_) => panic!("future is ready"),  in assert_not_ready()
847         Poll::Pending => {}  in assert_not_ready()