android - RxJava2 JUnit 测试

Question

我在对 RxJava 代码部分进行单元测试时遇到了一些麻烦。我想测试下面的方法。这是一个演示者方法。

public void onSearchQueryChanged(String searchQuery) {
    backendService.getShopResultsCount(searchQuery)
        .subscribeOn(Schedulers.io())
        .observeOn(AndroidSchedulers.mainThread())
        .subscribe(result -> {
            if (isViewAttached()) {
                getView().hideShopSearchInProgress();
                getView().displayShopSearchResultCount(result.getSearchResponse().getNumberOfHits());
            }
        }, error -> {
            if (isViewAttached()) {
                getView().hideShopSearchInProgress();
            }
        });
}

在最好的情况下，我想模拟 backendService 并针对特定搜索查询和附加/分离 View 测试此用例。

我做了一些研究，我知道 toBlocking() 和 test() 方法。他们都假设我有可用的 Observable。我想我必须以某种方式拆分该方法。您对此有何看法？

我的堆栈:RxJava2、 Dagger 、MVP。

Answer 1

在我们的项目中，我们编写如下代码:

Mockito.when(backendService.getShopResult(Mockito.any())).thenReturn(Observable.just(Some Data)

您可以通过以下方式解决调度程序:

@Inject
Scheduler subscribeOn;

并在测试中通过 Schedulers.test() 或 Schedulers.immediate()

或者你不能使用 TestRule 和 RxJavaPlugins.registerSchedulersHook()