Как запустить сопрограммы как блокировку для юнит-тестирования? - PullRequest
Новая
       25

Как запустить сопрограммы как блокировку для юнит-тестирования?

0 голосов
/ 23 декабря 2018

Я начал писать модульные тесты для своего проекта MVP Android, но мои тесты, зависящие от сопрограмм, периодически терпят неудачу (с помощью регистрации и отладки, которые я подтвердил, проверка иногда происходит рано, добавление delay исправляет это, конечно)

Я пытался обернуть runBlocking и обнаружил Dispatchers.setMain(mainThreadSurrogate) из org.jetbrains.kotlinx:kotlinx-coroutines-test, но попытка стольких комбинаций пока не принесла успеха. 

abstract class CoroutinePresenter : Presenter, CoroutineScope {
    private lateinit var job: Job

    override val coroutineContext: CoroutineContext
        get() = job + Dispatchers.Main

    override fun onCreate() {
        super.onCreate()
        job = Job()
    }

    override fun onDestroy() {
        super.onDestroy()
        job.cancel()
    }
}

class MainPresenter @Inject constructor(private val getInfoUsecase: GetInfoUsecase) : CoroutinePresenter() {
    lateinit var view: View

    fun inject(view: View) {
        this.view = view
    }

    override fun onResume() {
        super.onResume()

        refreshInfo()
    }

    fun refreshInfo() = launch {
        view.showLoading()
        view.showInfo(getInfoUsecase.getInfo())
        view.hideLoading()
    }

    interface View {
        fun showLoading()
        fun hideLoading()

        fun showInfo(info: Info)
    }
}

class MainPresenterTest {
    private val mainThreadSurrogate = newSingleThreadContext("Mocked UI thread")

    private lateinit var presenter: MainPresenter
    private lateinit var view: MainPresenter.View

    val expectedInfo = Info()

    @Before
    fun setUp() {
        Dispatchers.setMain(mainThreadSurrogate)

        view = mock()

        val mockInfoUseCase = mock<GetInfoUsecase> {
            on { runBlocking { getInfo() } } doReturn expectedInfo
        }

        presenter = MainPresenter(mockInfoUseCase)
        presenter.inject(view)
        presenter.onCreate()
    }

    @Test
    fun onResume_RefreshView() {
        presenter.onResume()

        verify(view).showLoading()
        verify(view).showInfo(expectedInfo)
        verify(view).hideLoading()
    }

    @After
    fun tearDown() {
        Dispatchers.resetMain()
        mainThreadSurrogate.close()
    }
}

Я считаю,блоки runBlocking должны заставить все дочерние элементы coroutineScopes работать в одном потоке, заставляя их завершить работу, прежде чем перейти к проверке.

Ответы [ 2 ]

0 голосов
/ 24 декабря 2018

@ Ответ Сергея заставил меня читать дальше в Dispatchers.Unconfined, и я понял, что не использую Dispatchers.setMain() в полной мере.На момент написания заметьте, что это решение является экспериментальным .

. Удаляя любые упоминания о: 

private val mainThreadSurrogate = newSingleThreadContext("Mocked UI thread")

и вместо этого устанавливая для главного диспетчера значение 

Dispatchers.setMain(Dispatchers.Unconfined)

Это приводит к тому же результату.

Менее идиоматический метод, который может помочь кому-либо в качестве временного решения - блокировать до тех пор, пока не будут выполнены все задания дочерних сопрограмм (кредит: https://stackoverflow.com/a/53335224/4101825):

this.coroutineContext[Job]!!.children.forEach { it.join() }
0 голосов
/ 23 декабря 2018

В CoroutinePresenter классе вы используете Dispatchers.Main.Вы должны быть в состоянии изменить это в тестах.Попробуйте сделать следующее:

  1. Добавить параметр uiContext: CoroutineContext в конструктор докладчиков: 

    abstract class CoroutinePresenter(private val uiContext: CoroutineContext = Dispatchers.Main) : CoroutineScope {
private lateinit var job: Job

override val coroutineContext: CoroutineContext
    get() = uiContext + job

//...
}

class MainPresenter(private val getInfoUsecase: GetInfoUsecase, 
                    private val uiContext: CoroutineContext = Dispatchers.Main 
) : CoroutinePresenter(uiContext) { ... }

  2. Изменить класс MainPresenterTest наввести еще один CoroutineContext: 

    class MainPresenterTest {
    private lateinit var presenter: MainPresenter

    @Mock
    private lateinit var view: MainPresenter.View

    @Mock
    private lateinit var mockInfoUseCase: GetInfoUsecase

    val expectedInfo = Info()

    @Before
    fun setUp() {
        // Mockito has a very convenient way to inject mocks by using the @Mock annotation. To
        // inject the mocks in the test the initMocks method needs to be called.
        MockitoAnnotations.initMocks(this)

        presenter = MainPresenter(mockInfoUseCase, Dispatchers.Unconfined) // here another CoroutineContext is injected 
        presenter.inject(view)
        presenter.onCreate()
}

    @Test
    fun onResume_RefreshView() = runBlocking {
        Mockito.`when`(mockInfoUseCase.getInfo()).thenReturn(expectedInfo)

        presenter.onResume()

        verify(view).showLoading()
        verify(view).showInfo(expectedInfo)
        verify(view).hideLoading()
    }
}
...