1

我使用 RxJava 2Observable将条形码扫描仪包装在我的一个应用程序中。这个片段展示了我如何订阅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()带有我提供的对象的事件。但这并没有发生。我究竟做错了什么？

4

2 回答 2

2

TestScheduler如果您需要使用流测试时间，这很有用。由于您对实现的唯一关注应该是同步运行流，因此您最好使用 aSchedulers.trampoline()代替。然后这将调用订阅和观察，而无需更改线程。

于 2018-04-06T06:49:05.957 回答
1

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

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

于 2018-04-06T06:00:29.750 回答