RxJava2：JUnitの環境で実行しているときのテスト

Question

にスローされる例外は以下のコードがクラッシュしないでしょう。しかし、それはアプリで実行中にクラッシュします。コンソールにエラーログが表示されますが、テストは合格とマークされます。

@Test 
    public void test() { 
    Observable observable = Observable.error(new RuntimeException()); 
    observable.subscribe(); 
    } 

したがって、問題は、JUnitでクラッシュさせる方法です。何かがアプリで動作しない場合、それはユニットテストでも:)

を動作しません。また、この例では、私が観察への直接アクセスを持っている場合ええ、それは良いことだから。しかし、私の本当のテストでは、私はそれを持っていません。実際の観測は、テストされているクラスの内部詳細です。私ができることのほとんどは、スケジューラなどを注入することです。

だから、どのように観察に直接アクセスしなくても、それがクラッシュするには？これはRxJava2特定の問題であるakarnokdすることにより

@Test 
    public void test() { 
    Observable observable = Observable.error(new RuntimeException()); 
    observable.subscribe(new Consumer() { 
     @Override 
     public void accept(Object o) throws Exception { 
     throw new RuntimeException(); 
     } 
    }, new Consumer<Throwable>() { 
     @Override 
     public void accept(Throwable throwable) throws Exception { 
     throw new RuntimeException(); 
     } 
    }); 
    } 

Answer 1

：

はまた、私はこのコードはいずれもクラッシュしませんチェックしました。

「このような用法は、もはや2.xで同期投げていないが、エラーのためのプラグインハンドラで終わります。」

任意のエラーが

public static List<Throwable> trackPluginErrors() { 
    final List<Throwable> list = Collections.synchronizedList(new ArrayList<Throwable>()); 

    RxJavaPlugins.setErrorHandler(new Consumer<Throwable>() { 
     @Override 
     public void accept(Throwable t) { 
      list.add(t); 
     } 
    }); 

    return list; 
} 

Answer 2

使用TestSubscriber

Observable observable = Observable.error(new RuntimeException()); 
    TestSubscriber testSubscriber = TestSubscriber.create(); 

    observable.subscribe(testSubscriber); 

    testSubscriber.assertTerminalEvent(); 
    testSubscriber.assertError(RuntimeException.class);