如何在RxJava 3中测试可完成错误?

Question

我正在编写可完成函数的单元测试。

在RxJava 2中，我们有blockingGet()文档:

Throwable t = myCompletable.blockingGet();
assertTrue(t instanceof MyException);

然而，在RxJava 3文档中，我再也没有看到blockingGet()了。

如何在RxJava 3中实现上述测试?

Answer 1

哦，原来RxJava的测试现在建议使用TestObserver类?

TestObserver testObserver = new TestObserver();
myCompletable.blockingSubscribe(testObserver);
testObserver.assertError(MyException.class);