单元测试RxJava上完成，上下一步和上错误

Question

我无法找到在android中对RxJava的onComplete、onNext和onError案例进行单元测试的方法。

TestSubcriber似乎解决了这个问题，但是作为RXJava的新手，我仍然不知道如何做到这一点。

MyApi.method()
    .subscribeOn(Schedulers.io())
    .observeOn(AndroidSchedulers.mainThread())
    .subscribe(object : Observer<SettleCodeResponse> {
        override fun onCompleted() {
        }

        override fun onError(e: Throwable) {
            view.hideProgress()
            Logger.logError(TAG, e.message)
        }

        override fun onNext(response: SettleCodeResponse) {
            view.hideProgress()
            process(response)
        }
    })

Answer 1

首先，您需要模拟myApi实例并定义myApi.method（）的响应。

您可以使用TestObserver根据响应断言接收链的不同场景。

@Test
fun test() {
    //mock the response of the method
    when(myApi.method()).thenReturn(Observable.just(someSettleCodeResponse())

    //create a test observer and subscribe
    val observable: Observable<SettleCodeResponse> = myApi.method()
    val observer: TestObserver<SettleCodeResponse> = TestObserver()
    observable.subscribe(observer)

    //test the observer behaviour
    observer.assertComplete()
            .assertNoErrors()
            .assertValue(someSettleCodeResponse())
}

您还可以测试整个流程，并查看是否调用了view方法。为此，您需要模拟您的myApi以及视图。假设代码是演示者或视图模型中方法的一部分。

@Test
fun anotherTest() {
    //mock the response of the method
    when(myApi.method()).thenReturn(Observable.just(someSettleCodeResponse())

    //call the method you want to test
    presenter.method()

    //test that the view mock methods are called
    verify(view).hideProgress()
}

Answer 2

我不确定是否要模拟静态类，但您可以尝试这种方法吗。

首先，你必须嘲笑MyApi。

在任何课堂上

class Foo(private val view: SomeView, private val myApi: MyApi) {
    fun doSomething() {
        myApi.method().subscribeOn(Schedulers.io())
            .observeOn(AndroidSchedulers.mainThread())
            .subscribe(object : Observer<SettleCodeResponse> {
                override fun onCompleted() {}

                override fun onError(e: Throwable) {
                    view.hideProgress()
                    Logger.logError(TAG, e.message)
                }

                override fun onNext(response: SettleCodeResponse) {
                    view.hideProgress()
                    process(response)
                }
            })
    }
}

在你的测试中

lateinit var myApi: MyApi
lateinit var view: SomeView
lateinit var foo: Foo

@Before
fun setup() {
    RxAndroidPlugins.setInitMainThreadSchedulerHandler({ Schedulers.trampoline() })
    MockitoAnnotations.initMocks(this)
    myApi = mock(MyApi:class.java)
    view = mock(SomeView::class.java)
    foo = Foo(view, myApi)
}

@Test
fun testOnNext() {
    given(myApi.method()).willReturn(SettleCodeResponse())
    foo.doSomething()
    verify(view).hideProgress()
}