Removed TERMINATED check in onNext (#5942)

* Removed pointless code.

* Removed unnecessary TERMINATED check.

Author: kjkrum

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);
         }

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);
         }