Проблема с PublishSubject и TestScheduler, элемент не выдан - PullRequest
Новая
       4

Проблема с PublishSubject и TestScheduler, элемент не выдан

0 голосов
/ 28 ноября 2018

У меня возникла проблема с предметами и TestSchedulers.Мои тесты проходят, если я использую планировщик 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()
            }
        }
    }

}

и класс My Contract - 

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)

thisтест проходит.

Может кто-нибудь пролить свет на это, спасибо заранее.Вот минимальная работоспособность проекта

1 Ответ

0 голосов
/ 29 ноября 2018

Большое спасибо @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()
    }
...