2.x: Verify same onNext / onError null behavior across all Subjects and Processors

src/main/java/io/reactivex/subjects/PublishSubject.java

@@ -175,7 +175,7 @@ public void onNext(T t) {
             return;
         }
         if (t == null) {
-            onError(new NullPointerException("onNext got a null value. Null values are generally not allowed in 2.x operators and sources."));
+            onError(new NullPointerException("onNext called with null. Null values are generally not allowed in 2.x operators and sources."));
             return;
         }
         for (PublishDisposable<T> s : subscribers.get()) {

src/test/java/io/reactivex/processors/AsyncProcessorTest.java

@@ -419,4 +419,28 @@ public void fusionOfflie() {
         .assertOf(SubscriberFusion.<Integer>assertFusionMode(QueueSubscription.ASYNC))
         .assertResult(1);
     }
-}
+
+    @Test
+    public void onNextNull() {
+        final AsyncProcessor<Object> p = AsyncProcessor.create();
+
+        p.onNext(null);
+
+        p.test()
+            .assertNoValues()
+            .assertError(NullPointerException.class)
+            .assertErrorMessage("onNext called with null. Null values are generally not allowed in 2.x operators and sources.");
+    }
+
+    @Test
+    public void onErrorNull() {
+        final AsyncProcessor<Object> p = AsyncProcessor.create();
+
+        p.onError(null);
+
+        p.test()
+            .assertNoValues()
+            .assertError(NullPointerException.class)
+            .assertErrorMessage("onError called with null. Null values are generally not allowed in 2.x operators and sources.");
+    }
+}

src/test/java/io/reactivex/processors/BehaviorProcessorTest.java

@@ -559,4 +559,28 @@ public void testCurrentStateMethodsError() {
         assertNull(as.getValue());
         assertTrue(as.getThrowable() instanceof TestException);
     }
-}
+
+    @Test
+    public void onNextNull() {
+        final BehaviorProcessor<Object> p = BehaviorProcessor.create();
+
+        p.onNext(null);
+
+        p.test()
+            .assertNoValues()
+            .assertError(NullPointerException.class)
+            .assertErrorMessage("onNext called with null. Null values are generally not allowed in 2.x operators and sources.");
+    }
+
+    @Test
+    public void onErrorNull() {
+        final BehaviorProcessor<Object> p = BehaviorProcessor.create();
+
+        p.onError(null);
+
+        p.test()
+            .assertNoValues()
+            .assertError(NullPointerException.class)
+            .assertErrorMessage("onError called with null. Null values are generally not allowed in 2.x operators and sources.");
+    }
+}

src/test/java/io/reactivex/processors/PublishProcessorTest.java

@@ -615,4 +615,28 @@ public void run() {
             TestHelper.race(r1, r2, Schedulers.io());
         }
     }
-}
+
+    @Test
+    public void onNextNull() {
+        final PublishProcessor<Object> p = PublishProcessor.create();
+
+        p.onNext(null);
+
+        p.test()
+            .assertNoValues()
+            .assertError(NullPointerException.class)
+            .assertErrorMessage("onNext called with null. Null values are generally not allowed in 2.x operators and sources.");
+    }
+
+    @Test
+    public void onErrorNull() {
+        final PublishProcessor<Object> p = PublishProcessor.create();
+
+        p.onError(null);
+
+        p.test()
+            .assertNoValues()
+            .assertError(NullPointerException.class)
+            .assertErrorMessage("onError called with null. Null values are generally not allowed in 2.x operators and sources.");
+    }
+}

src/test/java/io/reactivex/processors/ReplayProcessorTest.java

@@ -1016,4 +1016,28 @@ public void peekStateTimeAndSizeValue() {
 
         assertNull(rp.getValues(new Integer[2])[0]);
     }
-}
+
+    @Test
+    public void onNextNull() {
+        final ReplayProcessor<Object> p = ReplayProcessor.create();
+
+        p.onNext(null);
+
+        p.test()
+            .assertNoValues()
+            .assertError(NullPointerException.class)
+            .assertErrorMessage("onNext called with null. Null values are generally not allowed in 2.x operators and sources.");
+    }
+
+    @Test
+    public void onErrorNull() {
+        final ReplayProcessor<Object> p = ReplayProcessor.create();
+
+        p.onError(null);
+
+        p.test()
+            .assertNoValues()
+            .assertError(NullPointerException.class)
+            .assertErrorMessage("onError called with null. Null values are generally not allowed in 2.x operators and sources.");
+    }
+}

src/test/java/io/reactivex/processors/UnicastProcessorTest.java

@@ -129,23 +129,23 @@ public void zeroCapacityHint() {
 
     @Test
     public void onNextNull() {
-        final UnicastProcessor<Object> up = UnicastProcessor.create();
+        final UnicastProcessor<Object> p = UnicastProcessor.create();
 
-        up.onNext(null);
+        p.onNext(null);
 
-        up.test()
+        p.test()
             .assertNoValues()
             .assertError(NullPointerException.class)
             .assertErrorMessage("onNext called with null. Null values are generally not allowed in 2.x operators and sources.");
     }
 
     @Test
     public void onErrorNull() {
-        final UnicastProcessor<Object> up = UnicastProcessor.create();
+        final UnicastProcessor<Object> p = UnicastProcessor.create();
 
-        up.onError(null);
+        p.onError(null);
 
-        up.test()
+        p.test()
             .assertNoValues()
             .assertError(NullPointerException.class)
             .assertErrorMessage("onError called with null. Null values are generally not allowed in 2.x operators and sources.");

src/test/java/io/reactivex/subjects/AsyncSubjectTest.java

@@ -420,4 +420,27 @@ public void fusionOfflie() {
         .assertResult(1);
     }
 
-}
+    @Test
+    public void onNextNull() {
+        final AsyncSubject<Object> s = AsyncSubject.create();
+
+        s.onNext(null);
+
+        s.test()
+            .assertNoValues()
+            .assertError(NullPointerException.class)
+            .assertErrorMessage("onNext called with null. Null values are generally not allowed in 2.x operators and sources.");
+    }
+
+    @Test
+    public void onErrorNull() {
+        final AsyncSubject<Object> s = AsyncSubject.create();
+
+        s.onError(null);
+
+        s.test()
+            .assertNoValues()
+            .assertError(NullPointerException.class)
+            .assertErrorMessage("onError called with null. Null values are generally not allowed in 2.x operators and sources.");
+    }
+}

src/test/java/io/reactivex/subjects/BehaviorSubjectTest.java

@@ -559,4 +559,28 @@ public void testCurrentStateMethodsError() {
         assertNull(as.getValue());
         assertTrue(as.getThrowable() instanceof TestException);
     }
-}
+
+    @Test
+    public void onNextNull() {
+        final BehaviorSubject<Object> s = BehaviorSubject.create();
+
+        s.onNext(null);
+
+        s.test()
+            .assertNoValues()
+            .assertError(NullPointerException.class)
+            .assertErrorMessage("onNext called with null. Null values are generally not allowed in 2.x operators and sources.");
+    }
+
+    @Test
+    public void onErrorNull() {
+        final BehaviorSubject<Object> s = BehaviorSubject.create();
+
+        s.onError(null);
+
+        s.test()
+            .assertNoValues()
+            .assertError(NullPointerException.class)
+            .assertErrorMessage("onError called with null. Null values are generally not allowed in 2.x operators and sources.");
+    }
+}

src/test/java/io/reactivex/subjects/PublishSubjectTest.java

@@ -708,4 +708,27 @@ public void subscribedTo() {
         ts.assertResult(1, 2);
     }
 
-}
+    @Test
+    public void onNextNull() {
+        final PublishSubject<Object> s = PublishSubject.create();
+
+        s.onNext(null);
+
+        s.test()
+            .assertNoValues()
+            .assertError(NullPointerException.class)
+            .assertErrorMessage("onNext called with null. Null values are generally not allowed in 2.x operators and sources.");
+    }
+
+    @Test
+    public void onErrorNull() {
+        final PublishSubject<Object> s = PublishSubject.create();
+
+        s.onError(null);
+
+        s.test()
+            .assertNoValues()
+            .assertError(NullPointerException.class)
+            .assertErrorMessage("onError called with null. Null values are generally not allowed in 2.x operators and sources.");
+    }
+}

src/test/java/io/reactivex/subjects/ReplaySubjectTest.java

@@ -929,4 +929,27 @@ public void peekStateTimeAndSizeValue() {
         assertNull(rp.getValues(new Integer[2])[0]);
     }
 
-}
+    @Test
+    public void onNextNull() {
+        final ReplaySubject<Object> s = ReplaySubject.create();
+
+        s.onNext(null);
+
+        s.test()
+            .assertNoValues()
+            .assertError(NullPointerException.class)
+            .assertErrorMessage("onNext called with null. Null values are generally not allowed in 2.x operators and sources.");
+    }
+
+    @Test
+    public void onErrorNull() {
+        final ReplaySubject<Object> s = ReplaySubject.create();
+
+        s.onError(null);
+
+        s.test()
+            .assertNoValues()
+            .assertError(NullPointerException.class)
+            .assertErrorMessage("onError called with null. Null values are generally not allowed in 2.x operators and sources.");
+    }
+}

src/test/java/io/reactivex/subjects/UnicastSubjectTest.java

@@ -129,23 +129,23 @@ public void zeroCapacityHint() {
 
     @Test
     public void onNextNull() {
-        final UnicastSubject<Object> up = UnicastSubject.create();
+        final UnicastSubject<Object> s = UnicastSubject.create();
 
-        up.onNext(null);
+        s.onNext(null);
 
-        up.test()
+        s.test()
             .assertNoValues()
             .assertError(NullPointerException.class)
             .assertErrorMessage("onNext called with null. Null values are generally not allowed in 2.x operators and sources.");
     }
 
     @Test
     public void onErrorNull() {
-        final UnicastSubject<Object> up = UnicastSubject.create();
+        final UnicastSubject<Object> s = UnicastSubject.create();
 
-        up.onError(null);
+        s.onError(null);
 
-        up.test()
+        s.test()
             .assertNoValues()
             .assertError(NullPointerException.class)
             .assertErrorMessage("onError called with null. Null values are generally not allowed in 2.x operators and sources.");