RxJava 2 模拟 Observable 不起作用

Question

我使用 RxJava 2 Observable 在我的一个应用程序中封装条码扫描器。此片段展示了我如何订阅 Observable 并收听它的事件

override fun start() {
    disposables.addAll(subscribeToBarcodeReader(), loadUser())
}

private fun subscribeToBarcodeReader(): Disposable {
    return barcodeObservable
        .subscribeOn(bgScheduler)
        .observeOn(mainScheduler)
        .subscribeBy(
                onNext = { barcode -> saveBarcode(barcode) },
                onComplete = { Log.d(TAG, "Barcode observable complete") },
                onError = { e -> Log.d(TAG, "Barcode observable error", e) }
        )
}

barcodeObservable 是 Observable<Barcode> 类型的对象。这一切在带有真实条形码扫描仪的真实设备上都可以正常工作。现在我想对 saveBarcode() 方法进行单元测试，并尝试以这种方式模拟 Observable<Barcode>

@RunWith(MockitoJUnitRunner::class)
class OrbFoldersPresenterTests {

    @Mock
    private lateinit var jobService: FolderJobService
    private val bgScheduler = TestScheduler()
    private val mainScheduler = TestScheduler()
    private val barcodeObservable: Observable<Barcode> = Observable.just(Barcode(
            "2500020109205", LocalDateTime.now().toString()))
    @Mock
    private lateinit var userStore: UserStore
    @Mock
    private lateinit var prefs: Preferences
    @Mock
    private lateinit var barcodeService: BarcodeReadService

    @Test
    fun testBarcodeSave() {
        val jobId = 201804040001
        val disposables = CompositeDisposable()

        whenever(userStore.authorizedUser()).thenReturn(Maybe.just(User()))

        val presenter = OrbFoldersPresenter(jobId, jobService, disposables, bgScheduler,
                mainScheduler, barcodeObservable, userStore, prefs, barcodeService)
        presenter.start()
    }
}

我希望当我调用 presenter.start() 时，演示者必须订阅 barcodeObservable 并接收 onNext() 事件以及我提供的对象。但这并没有发生。我究竟做错了什么？

Answer 1

由于订阅和观察给定的调度程序，正在进行异步处理。 onNext() 没有像您的测试代码预期的那样被同步调用。

使用 TestScheduler，您可以例如调用 triggerActions() 或 advanceTimeBy() 来执行异步代码。

Answer 2

如果您需要测试流的计时，TestScheduler 很有用。由于您对实现的唯一关注应该是同步运行流，因此您最好改用 Schedulers.trampoline()。然后，这将在不更改线程的情况下调用订阅和观察。

RxJava 2 模拟 Observable 不起作用

RxJava 2 mock Observable doesn't work

android

kotlin

rx-java2

rx-kotlin2