Skip to content

Commit e85c404

Browse files
committed
Properly wired up SynchronizedObserver within MergeDelayError operator
1 parent 7ec374c commit e85c404

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

rxjava-core/src/main/java/rx/operators/OperationMergeDelayError.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -168,7 +168,7 @@ public Subscription onSubscribe(Observer<? super T> actualObserver) {
168168
/**
169169
* Subscribe to the parent Observable to get to the children Observables
170170
*/
171-
completeSubscription.add(sequences.subscribe(new ParentObserver(actualObserver)));
171+
completeSubscription.add(sequences.subscribe(new ParentObserver(synchronizedObserver)));
172172

173173
/* return our subscription to allow unsubscribing */
174174
return completeSubscription;

0 commit comments

Comments
 (0)