PublishSubject 和 TestScheduler 的问题，未发出项目答案

【问题标题】：Issue with PublishSubject and TestScheduler, item isn't emittedPublishSubject 和 TestScheduler 的问题，未发出项目
【发布时间】：2018-11-28 12:19:21
【问题描述】：

我一直面临着主题和 TestScheduler 的问题。如果我使用 Trampoline 调度程序，我的测试通过，但由于某种原因，如果我使用 TestScheduler，它们会失败。

这是我的示例测试和相关课程。

@RunWith(MockitoJUnitRunner::class)
class DemoViewModelTest  {


    //Error Mocks
    private val actionsStream: PublishSubject<DemoContract.ViewEvent> = PublishSubject.create()

    private lateinit var viewModel: DemoViewModel

    private val handler = mock(DemoContract.Handler::class.java)

    @Before
    fun setup() {
        viewModel = DemoViewModel(schedulersProvider, handler)
        viewModel.viewEventsStream = actionsStream
    }

    @Test
    fun testUpdateCounter() {
        actionsStream.onNext(DemoContract.ViewEvent.UpdateClick)
        testScheduler.triggerActions()
        verify(handler).onUpdate()

    }


    protected var testScheduler = TestScheduler()

    protected var schedulersProvider: SchedulersProvider = object : SchedulersProvider() {
        override fun mainThread(): Scheduler {
            return testScheduler
        }

        override fun io(): Scheduler {
            return testScheduler
        }

        override fun computation(): Scheduler {
            return testScheduler
        }

        override fun newThread(): Scheduler {
            return testScheduler
        }

        override fun trampoline(): Scheduler {
            return testScheduler
        }

        override fun single(): Scheduler {
            return testScheduler
        }
    }
}

还有我的 ViewModel 类

class DemoViewModel (val schedulersProvider: SchedulersProvider, val handler:DemoContract.Handler) : DemoContract.ViewModel() {

    var viewEventsStream: Observable<DemoContract.ViewEvent>? = null
        set(value) {
            field = value
            subscribeToViewEvents()
        }

    private fun subscribeToViewEvents() {
        viewEventsStream?.let {
            it.subscribeOn(schedulersProvider.io())
                .observeOn(schedulersProvider.mainThread())
                .subscribe(object:Observer<DemoContract.ViewEvent>{
                    override fun onComplete() {

                    }

                    override fun onSubscribe(d: Disposable) {
                    }

                    override fun onNext(t: DemoContract.ViewEvent) {
                        onViewEvent(t)
                    }

                    override fun onError(e: Throwable) {
                    }

                })

        }
    }
     fun onViewEvent(event: DemoContract.ViewEvent) {
        when (event) {
            is DemoContract.ViewEvent.UpdateClick -> {
               handler.onUpdate()
            }
        }
    }

}

我的合同类是

interface DemoContract {
        abstract class ViewModel

        sealed class ViewEvent {
            object UpdateClick : ViewEvent()
        }

        interface Handler{
            fun onUpdate()
        }
    }

关于这个的一些事情，如果我替换

viewModel.viewEventsStream = actionsStream

与

viewModel.viewEventsStream = Observable.just(DemoContract.ViewEvent.Update)

此测试通过。

有人能说明一下吗，在此先感谢。这是最小可运行project

【问题讨论】：

如果在subscribeOn() 运算符之前插入日志语句会发生什么？试试.doOnNext( v -> logger.debug(v.toString()) -
它不会被调用，如果你愿意，这是一个简单的可重现的 git 项目。 gitlab.com/anvith/testissues
在调用onNext之前检查actionsStream.hasObservers是否为真。
有人叫过subscribeToViewEvents吗？
actionsStream.hasObservers 是假的

标签： android unit-testing testing rx-java rx-android

【解决方案1】：

非常感谢@akarnokd 为我指明了正确的方向。事实证明，这是正在添加的PublishSubject 的订阅者（subscribeActual 调用）和我在测试中触发的 onNext 调用之间的竞争条件。 onNext 调用在前者发生之前返回。

解决方案是在订阅后立即显式调用triggerActions 两次，在发射后调用一次。

改变这个

    @Before
    fun setup() {
        viewModel = DemoViewModel(schedulersProvider, handler)
        viewModel.viewEventsStream = actionsStream
    }

到

    @Before
    fun setup() {
        viewModel = DemoViewModel(schedulersProvider, handler)
        viewModel.viewEventsStream = actionsStream
        testScheduler.triggerActions()
    }

【讨论】：