Skip to content

Commit fcb7657

Browse files
Fix #544 ReplaySubject emits items received after onError
1 parent 212cec5 commit fcb7657

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

rxjava-core/src/main/java/rx/subjects/ReplaySubject.java

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -164,6 +164,9 @@ public void onError(Throwable e)
164164
public void onNext(T args)
165165
{
166166
synchronized (subscriptions) {
167+
if (isDone) {
168+
return;
169+
}
167170
history.add(args);
168171
for (Observer<? super T> observer : new ArrayList<Observer<? super T>>(subscriptions.values())) {
169172
observer.onNext(args);

0 commit comments

Comments
 (0)