RxJava2 с JUnit: исключений, исключенных в тестах

Question

Код ниже не работает при работе в среде JUnit. Но он падает при запуске приложения. Я вижу журналы ошибок в консоли, но тесты отмечены как переданные.

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

Итак, вопрос в том, как это произошло в JUnit. Потому что да, если что-то не работает в приложении, это хорошо, если он также не работает в модульных тестах :)

И в этом примере у меня есть прямой доступ к наблюдаемому. Но в моих реальных тестах у меня этого нет. Реальные наблюдаемые - это только внутренние детали тестируемых классов. Самое главное, что я могу сделать, это добавить планировщиков или что-то еще.

Итак, как сделать так, чтобы он не имел прямого доступа к наблюдаемому?

Кроме того, я только что проверил этот код не врезаться либо:

@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

Согласно akarnokd это RxJava2 конкретная проблема.

«Такие обычаи больше не синхронизируются в 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);