Remove unnecessary pin projection

Author: taiki-e

futures-util/src/stream/catch_unwind.rs

@@ -31,7 +31,7 @@ impl<St: Stream + UnwindSafe> Stream for CatchUnwind<St>
         mut self: Pin<&mut Self>,
         cx: &mut Context<'_>,
     ) -> Poll<Option<Self::Item>> {
-        if *self.as_mut().caught_unwind() {
+        if self.caught_unwind {
             Poll::Ready(None)
         } else {
             let res = catch_unwind(AssertUnwindSafe(|| {

futures-util/src/stream/filter.rs

@@ -99,7 +99,7 @@ impl<St, Fut, F> Stream for Filter<St, Fut, F>
         cx: &mut Context<'_>,
     ) -> Poll<Option<St::Item>> {
         loop {
-            if self.as_mut().pending_fut().as_pin_mut().is_none() {
+            if self.pending_fut.is_none() {
                 let item = match ready!(self.as_mut().stream().poll_next(cx)) {
                     Some(e) => e,
                     None => return Poll::Ready(None),

futures-util/src/stream/filter_map.rs

@@ -92,7 +92,7 @@ impl<St, Fut, F, T> Stream for FilterMap<St, Fut, F>
         cx: &mut Context<'_>,
     ) -> Poll<Option<T>> {
         loop {
-            if self.as_mut().pending().as_pin_mut().is_none() {
+            if self.pending.is_none() {
                 let item = match ready!(self.as_mut().stream().poll_next(cx)) {
                     Some(e) => e,
                     None => return Poll::Ready(None),

futures-util/src/stream/flatten.rs

@@ -80,7 +80,7 @@ impl<St> Stream for Flatten<St>
         cx: &mut Context<'_>,
     ) -> Poll<Option<Self::Item>> {
         loop {
-            if self.as_mut().next().as_pin_mut().is_none() {
+            if self.next.is_none() {
                 match ready!(self.as_mut().stream().poll_next(cx)) {
                     Some(e) => self.as_mut().next().set(Some(e)),
                     None => return Poll::Ready(None),

futures-util/src/stream/fold.rs

@@ -52,7 +52,7 @@ impl<St, Fut, T, F> Future for Fold<St, Fut, T, F>
     fn poll(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<T> {
         loop {
             // we're currently processing a future to produce a new accum value
-            if self.as_mut().accum().is_none() {
+            if self.accum.is_none() {
                 let accum = ready!(self.as_mut().future().as_pin_mut().unwrap().poll(cx));
                 *self.as_mut().accum() = Some(accum);
                 self.as_mut().future().set(None);

futures-util/src/stream/for_each_concurrent.rs

@@ -92,7 +92,7 @@ impl<St, Fut, F> Future for ForEachConcurrent<St, Fut, F>
             match self.as_mut().futures().poll_next_unpin(cx) {
                 Poll::Ready(Some(())) => made_progress_this_iter = true,
                 Poll::Ready(None) => {
-                    if self.as_mut().stream().is_none() {
+                    if self.stream.is_none() {
                         return Poll::Ready(())
                     }
                 },

futures-util/src/stream/fuse.rs

@@ -77,7 +77,7 @@ impl<S: Stream> Stream for Fuse<S> {
         mut self: Pin<&mut Self>,
         cx: &mut Context<'_>,
     ) -> Poll<Option<S::Item>> {
-        if *self.as_mut().done() {
+        if self.done {
             return Poll::Ready(None);
         }
 

futures-util/src/stream/then.rs

@@ -82,7 +82,7 @@ impl<St, Fut, F> Stream for Then<St, Fut, F>
         mut self: Pin<&mut Self>,
         cx: &mut Context<'_>,
     ) -> Poll<Option<Fut::Output>> {
-        if self.as_mut().future().as_pin_mut().is_none() {
+        if self.future.is_none() {
             let item = match ready!(self.as_mut().stream().poll_next(cx)) {
                 None => return Poll::Ready(None),
                 Some(e) => e,

futures-util/src/stream/zip.rs

@@ -90,7 +90,7 @@ impl<St1, St2> Stream for Zip<St1, St2>
                 Poll::Ready(None) | Poll::Pending => {}
             }
         }
-        if self.as_mut().queued2().is_none() {
+        if self.queued2.is_none() {
             match self.as_mut().stream2().poll_next(cx) {
                 Poll::Ready(Some(item2)) => *self.as_mut().queued2() = Some(item2),
                 Poll::Ready(None) | Poll::Pending => {}

futures-util/src/try_stream/try_fold.rs

@@ -52,7 +52,7 @@ impl<St, Fut, T, F> Future for TryFold<St, Fut, T, F>
     fn poll(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> {
         loop {
             // we're currently processing a future to produce a new accum value
-            if self.as_mut().accum().is_none() {
+            if self.accum.is_none() {
                 let accum = match ready!(
                     self.as_mut().future().as_pin_mut()
                        .expect("TryFold polled after completion")