Fix ReactiveX#544 ReplaySubject emits items received after onError

rickbw · Dec 11, 2013 · 8cb9e9b · 8cb9e9b
1 parent 72bf445
commit 8cb9e9b
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/rxjava-core/src/main/java/rx/subjects/ReplaySubject.java b/rxjava-core/src/main/java/rx/subjects/ReplaySubject.java
@@ -164,6 +164,9 @@ public void onError(Throwable e)
     public void onNext(T args)
     {
         synchronized (subscriptions) {
+            if (isDone) {
+                return;
+            }
             history.add(args);
             for (Observer<? super T> observer : new ArrayList<Observer<? super T>>(subscriptions.values())) {
                 observer.onNext(args);