Android项目中带有反应式编程的Junit

Question

我正试图在一个Android项目中使用JUnit4，其中我还使用RxAndroid/RxJava。

我所做的是从使用改造UUID生成器调用REST API

乌伊达皮。java只是一个用于改装调用的接口（现在只是其中之一）

public interface UUIDApi {

    static final String BASE_URL = "https://www.uuidgenerator.net";

    @GET("/api/version4")
    Observable<String> getUUID();
}

UUID模型。java，其中初始化了改造，并实现了上面编写的接口

public class UUIDModel implements UUIDApi{
    private Retrofit retrofit;
    private UUIDApi uuidApi;
    UUIDObserver uuidObserver = new UUIDObserver();

    public UUIDModel() {
        retrofit = new Retrofit.Builder()
                .addCallAdapterFactory(RxJava2CallAdapterFactory.create())
                .addConverterFactory(new ToStringConverterFactory())
                .baseUrl(UUIDApi.BASE_URL)
                .build();
        uuidApi = retrofit.create(UUIDApi.class);
    }

    @Override
    public Observable<String> getUUID() {
        return uuidApi.getUUID();
    }

    public void generateUUID(){
        Observable<String> observable =  this.getUUID();
        observable.subscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe(uuidObserver);
    }
}

比我有UUID观察者，这只是一个实现观察者的类。

注意：new ToStringConverterFactory是我在这里找到的一个类

使用emulator执行此代码，我确信它工作正常。问题是我不理解如何junit这段代码，因为使用rxAndroid/rxJava它会在另一个线程中执行。

我读到：

测试可观察对象的正式方法是使用TestSubscriber，这是RxJava库直接提供的助手订阅者。

所以我试过了

@Test
    public void test_uuid() throws Exception {
        UUIDApi uuidApi = new UUIDModel();
        Observable<String> observable = uuidApi.getUUID();

        TestSubscriber<String> testSubscriber = new TestSubscriber<>();
        observable.subscribe(testSubscriber);

    }

但是在observable.subscribe（testSubscriber）；我得到错误'无法解决方法'订阅（io.reactivex.subscribers.TestSubscriber）'

我做错了什么？我应该如何处理rxProgramming和JUnit？

Answer 1

您可以使用test操作符向testobservate订阅您的observatable，它记录事件并允许您对事件做出断言：

observable
    .test()
    .assertValue(...)
    .assertComplete()
    //etc

要处理反应流中的异步操作，可以尝试以下方法：

>

利用TestObserver（测试观察者）的handy（等待）操作符，直到TestObserver（测试观察者）接收到onError（错误）或onComplete（完成）事件。

通过依赖项注入（例如，使用构造函数注入）提供调度程序，以便您可以在测试中用调度程序替换它们。蹦床。

使用RxJava的挂钩函数之一（例如RxJavaPlugins.setInitIoSchedulerHandler）更改您的异步调度程序的默认实现。

Answer 2

我正在测试RxJavaRetrofit这样：

首先，我使用的是调度程序。蹦床（），用于测试。然后在基本单元测试中：

@Mock
ResponseBody mockResponseBody;

@Test
public void testCondition(){
    when(mService.operation()).thenReturn(Observable.just(response));

    mPresenter.handleOperation();

    verify(mView).operationResult();
}

我正在测试3个案例：成功响应（200-300），错误响应，失败

测试成功：<代码>响应=响应。成功（你的身体）

对于测试错误：<代码>响应=响应。错误（any\u error\u code，mockResponseBody）

对于测试失败：只需返回可观察的。错误（） 内部<代码>然后返回

在这个单元测试中，我们嘲笑我们的webservice调用，它永远不依赖于webservice，因此即使您离线，您也可以运行单元测试。

但是如果您想查看真正的webservice调用，您可以编写集成测试。

Answer 3

TestSubscriber与Flowable相关，而TestObserver与Observable一起使用。但对于这两者，您实际上不必手动订阅任何内容。您只需使用test（）方法即可。

observable.test()
      .assertNoErrors()
      .assertValue(expected)
      .assertComplete();