child.onNext should not be called after child.onError

ReactiveX · Apr 16, 2015 · 580dad2 · 580dad2
1 parent 131a663
commit 580dad2
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/src/main/java/rx/internal/operators/OperatorScan.java b/src/main/java/rx/internal/operators/OperatorScan.java
@@ -104,6 +104,7 @@ public void onNext(T currentValue) {
                         this.value = accumulator.call(this.value, currentValue);
                     } catch (Throwable e) {
                         child.onError(OnErrorThrowable.addValueAsLastCause(e, currentValue));
+                        return;
                     }
                 }
                 child.onNext(this.value);