diff --git a/rxjava-core/src/main/java/rx/subjects/ReplaySubject.java b/rxjava-core/src/main/java/rx/subjects/ReplaySubject.java index 13d0cc3b57b..c4985ba84ac 100644 --- 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 observer : new ArrayList>(subscriptions.values())) { observer.onNext(args);