Merge pull request ReactiveX#628 from mattrjacobs/fix-merge-delay-error

Properly wired up SynchronizedObserver within MergeDelayError operator
rickbw · Dec 16, 2013 · 9c9076e · 9c9076e
2 parents 442a29c + dd81411
commit 9c9076e
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/rxjava-core/src/main/java/rx/operators/OperationMergeDelayError.java b/rxjava-core/src/main/java/rx/operators/OperationMergeDelayError.java
@@ -168,7 +168,7 @@ public Subscription onSubscribe(Observer<? super T> actualObserver) {
             /**
              * Subscribe to the parent Observable to get to the children Observables
              */
-            completeSubscription.add(sequences.subscribe(new ParentObserver(actualObserver)));
+            completeSubscription.add(sequences.subscribe(new ParentObserver(synchronizedObserver)));
 
             /* return our subscription to allow unsubscribing */
             return completeSubscription;