diff --git a/src/main/java/com/aol/cyclops/types/stream/reactive/SeqSubscriber.java b/src/main/java/com/aol/cyclops/types/stream/reactive/SeqSubscriber.java
index <HASH>..<HASH> 100644
--- a/src/main/java/com/aol/cyclops/types/stream/reactive/SeqSubscriber.java
+++ b/src/main/java/com/aol/cyclops/types/stream/reactive/SeqSubscriber.java
@@ -113,20 +113,20 @@ public class SeqSubscriber<T> implements Subscriber<T>,
         @Override
         public Iterator<T> iterator() {
             return new Iterator<T>(){
-                boolean first = true;
+                boolean requested = true;
                 @Override
                 public boolean hasNext() {
+                    if(!complete && !requested){
+                        reset();
+                        requestOne.run();
+                        requested =true;
+                    }
                     return !complete;
                 }
 
                 @Override
                 public T next() {
-                   if(!first){
-                       reset();
-                       requestOne.run();
-                   }
-                   else
-                       first = false;
+                   requested = false;
                    return get();
                 }
fix SeqSubcuver oncomplete issue