Removed TERMINATED check in onNext (#5942)

* Removed pointless code. * Removed unnecessary TERMINATED check.
ReactiveX · Apr 1, 2018 · 2770e4d · 2770e4d
1 parent 1706fe1
commit 2770e4d
Show file tree

Hide file tree

Showing 2 changed files with 0 additions and 7 deletions.
diff --git a/src/main/java/io/reactivex/processors/PublishProcessor.java b/src/main/java/io/reactivex/processors/PublishProcessor.java
@@ -189,9 +189,6 @@ public void onSubscribe(Subscription s) {
     @Override
     public void onNext(T t) {
         ObjectHelper.requireNonNull(t, "onNext called with null. Null values are generally not allowed in 2.x operators and sources.");
-        if (subscribers.get() == TERMINATED) {
-            return;
-        }
         for (PublishSubscription<T> s : subscribers.get()) {
             s.onNext(t);
         }

diff --git a/src/main/java/io/reactivex/subjects/PublishSubject.java b/src/main/java/io/reactivex/subjects/PublishSubject.java
@@ -225,10 +225,6 @@ public void onSubscribe(Disposable s) {
     @Override
     public void onNext(T t) {
         ObjectHelper.requireNonNull(t, "onNext called with null. Null values are generally not allowed in 2.x operators and sources.");
-
-        if (subscribers.get() == TERMINATED) {
-            return;
-        }
         for (PublishDisposable<T> s : subscribers.get()) {
             s.onNext(t);
         }