Update iterables.

Author: gk-brown

kilo-client/src/main/java/org/httprpc/kilo/util/Iterables.java

@@ -41,12 +41,14 @@ private static class FilterIterator<T> implements Iterator<T> {
         public boolean hasNext() {
             if (hasNext == null) {
                 hasNext = Boolean.FALSE;
+                next = null;
 
                 while (iterator.hasNext()) {
-                    next = iterator.next();
+                    var element = iterator.next();
 
-                    if (predicate.test(next)) {
+                    if (predicate.test(element)) {
                         hasNext = Boolean.TRUE;
+                        next = element;
 
                         break;
                     }

kilo-client/src/main/java/org/httprpc/kilo/util/concurrent/Pipe.java

@@ -41,26 +41,26 @@ public class Pipe<E> implements Iterable<E> {
         public boolean hasNext() {
             if (hasNext == null) {
                 hasNext = Boolean.FALSE;
+                next = null;
 
-                Object next;
+                Object value;
                 try {
                     if (timeout == 0) {
-                        next = queue.take();
+                        value = queue.take();
                     } else {
-                        next = queue.poll(timeout, TimeUnit.MILLISECONDS);
+                        value = queue.poll(timeout, TimeUnit.MILLISECONDS);
 
-                        if (next == null) {
+                        if (value == null) {
                             throw new TimeoutException("Poll timed out.");
                         }
                     }
                 } catch (InterruptedException exception) {
                     throw new RuntimeException(exception);
                 }
 
-                if (next != TERMINATOR) {
+                if (value != TERMINATOR) {
                     hasNext = Boolean.TRUE;
-
-                    this.next = (E)next;
+                    next = (E)value;
                 }
             }