Vfrdtyky

I need help. I'm using Kotlin 1.2, RxJava2 (2.0.2), Retrofit2 (2.4.0) and mockito (2.22.0). I have MVP project I need to test. I want to know if function getPastEventList reach result block and not error block. Optionally, I should know the data received inside result block.

My Presenter is like this:

import android.content.Context

import android.widget.Toast

import ..ApiService

import ..RxJavaUtils

import ..MatchesView

import io.reactivex.disposables.Disposable



class MatchesPresenter(

    private val view: MatchesView

    , private val apiService: ApiService

) {



    fun getPastEventList(context: Context?, eventId: Int): Disposable? {

        view.showLoading()



        return apiService.getPastMatches(eventId.toString())

            .subscribeOn(RxJavaUtils.getSubscriberOn.invoke())

            .observeOn(RxJavaUtils.getObserveOn.invoke())

            .subscribe(

                { result -> //I want to know via mockito, if this request reach here (not reaching to error block below)

                    run {

                        view.hideLoading()

                        view.showEventList(

                            result.events //optional: I want to get this data via mockito

                        )

                    }

                },

                { error -> //I want to know via mockito, if this request not reach here

                    Toast.makeText(context, error.message, Toast.LENGTH_SHORT).show()

                }

            )

    }

my ApiService is like this:

interface ApiService {

    @GET("eventspastleague.php")

    fun getPastMatches(@Query("id") action: String):

            Observable<EventModel.Events>

}

RxJavaUtils class is like this:

import io.reactivex.android.schedulers.AndroidSchedulers

import io.reactivex.schedulers.Schedulers



object RxJavaUtils {

    var getSubscriberOn = { Schedulers.io() }

    var getObserveOn = { AndroidSchedulers.mainThread() }

}

And my attempt so far is like this:

import android.content.Context

import ..RxJavaUtils.getObserveOn

import ..RxJavaUtils.getSubscriberOn

import ..model.EventModel

import ..presenter.MatchesPresenter

import ..view.MatchesView

import io.reactivex.schedulers.Schedulers

import org.junit.Before

import org.junit.Test

import org.mockito.Mock

import org.mockito.Mockito.`when`

import org.mockito.Mockito.mock

import org.mockito.MockitoAnnotations



class MatchesPresenterTest {



    @Mock

    private

    lateinit var view: MatchesView



    @Mock

    private lateinit var presenter: MatchesPresenter



    @Before

    fun setUp() {

        MockitoAnnotations.initMocks(this)

        presenter = MatchesPresenter(view,  ApiService.create())

    }



    @Before

    fun init() {

        getSubscriberOn = { Schedulers.from { command -> command.run() } } //Runs in current thread

        getObserveOn = { Schedulers.from { command -> command.run() } } //runs also in current thread

    }    



    @Test

    fun testGetPastEventList() {

        val context = mock(Context::class.java)

        var events : List<EventModel.Event>



        val eventId = 4328;



        `when`(

            presenter.getPastEventList(context, eventId) //return Disposable

        )

        .thenReturn( //did I wrong, if I am using this method to know subscribe result?

             //what to do?

        )

        // do I need to call another method?

    }



}

I'm really stuck. I've read many stackoverflow & medium posts, but seems none of those articles can be applied here. Many thanks for any help.