File tree Expand file tree Collapse file tree 2 files changed +3
-3
lines changed
src/main/java/io/reactivex Expand file tree Collapse file tree 2 files changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -149,7 +149,7 @@ public void onNext(T t) {
149
149
values .add (t );
150
150
151
151
if (t == null ) {
152
- errors .add (new NullPointerException ("onNext received a null Subscription " ));
152
+ errors .add (new NullPointerException ("onNext received a null value " ));
153
153
}
154
154
155
155
actual .onNext (t );
Original file line number Diff line number Diff line change @@ -207,7 +207,7 @@ public void onNext(T t) {
207
207
values .add (t );
208
208
209
209
if (t == null ) {
210
- errors .add (new NullPointerException ("onNext received a null Subscription " ));
210
+ errors .add (new NullPointerException ("onNext received a null value " ));
211
211
}
212
212
213
213
actual .onNext (t );
@@ -226,7 +226,7 @@ public void onError(Throwable t) {
226
226
errors .add (t );
227
227
228
228
if (t == null ) {
229
- errors .add (new IllegalStateException ("onError received a null Subscription " ));
229
+ errors .add (new IllegalStateException ("onError received a null Throwable " ));
230
230
}
231
231
232
232
actual .onError (t );
You can’t perform that action at this time.
0 commit comments