File tree Expand file tree Collapse file tree 1 file changed +2
-1
lines changed
src/test/java/rx/observers Expand file tree Collapse file tree 1 file changed +2
-1
lines changed Original file line number Diff line number Diff line change @@ -674,6 +674,7 @@ public TestMultiThreadedObservable(String... values) {
674
674
675
675
@ Override
676
676
public void call (final Subscriber <? super String > observer ) {
677
+ final NullPointerException npe = new NullPointerException ();
677
678
System .out .println ("TestMultiThreadedObservable subscribed to ..." );
678
679
t = new Thread (new Runnable () {
679
680
@@ -694,7 +695,7 @@ public void run() {
694
695
System .out .println ("TestMultiThreadedObservable onNext: " + s + " on thread " + Thread .currentThread ().getName ());
695
696
if (s == null ) {
696
697
// force an error
697
- throw new NullPointerException () ;
698
+ throw npe ;
698
699
} else {
699
700
// allow the exception to queue up
700
701
int sleep = (fj % 3 ) * 10 ;
You can’t perform that action at this time.
0 commit comments