From e85c4045e340c0573550894b8865b043b9689487 Mon Sep 17 00:00:00 2001 From: Matt Jacobs Date: Mon, 16 Dec 2013 11:01:03 -0800 Subject: [PATCH] Properly wired up SynchronizedObserver within MergeDelayError operator --- .../src/main/java/rx/operators/OperationMergeDelayError.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/rxjava-core/src/main/java/rx/operators/OperationMergeDelayError.java b/rxjava-core/src/main/java/rx/operators/OperationMergeDelayError.java index d899ca1149..704ea181f1 100644 --- 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 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;