Как протестировать функцию с RxJava

Подскажите как написать unit тест для такой функции:

   fun fetchEvents() {
        getEventsUseCase.execute()
            .subscribeOn(schedulerProvider.io())
            .doOnSubscribe { disposable ->
                compositeDisposable.add(disposable)
                viewState.setViewsLoading(true)
            }
            .map { it.map(mapper::mapToUiModel) }
            .observeOn(schedulerProvider.main())
            .subscribe { events ->
                viewState.setItems(events)
                viewState.setViewsLoading(false)
            }
    }

Здесь я хочу протестировать, что методы viewState были вызваны с верными параметрами, но не понимаю, как это сделать с rxjava.