KaneAI - World’s First E2E Software Testing Agent.Signup for Private Beta Join TestMu Conference

How to use CoroutinesTest class of test package

Best Mockito-kotlin code snippet using test.CoroutinesTest

EitherFlowUtilsTest.kt

Source:EitherFlowUtilsTest.kt

...4import kotlinx.coroutines.flow.flow5import kotlinx.coroutines.flow.flowOf6import kotlinx.coroutines.flow.map7import kotlinx.coroutines.flow.toList8import util.test.CoroutinesTest9import kotlin.test.*10internal class EitherFlowUtilsTest : CoroutinesTest {11    @Test12    fun `foldMap works correctly`() = coroutinesTest {13        val source = flowOf(1.left(), "2".right())14        val result = source.foldMap({ it.toString() }, { it.toInt() })15        val (first, second) = result.toList()16        assert that first *{17            +leftOrNull() `is` type<String>()18            +leftOrNull() equals 119            +rightOrNull() `is` Null20        }21        assert that second *{22            +rightOrNull() `is` type<Int>()23            +rightOrNull() equals 224            +leftOrNull() `is` Null...

MainActivity.kt

Source:MainActivity.kt

1package com.example.threadstest2import android.Manifest3import android.content.pm.PackageManager4import android.os.Bundle5import androidx.appcompat.app.AppCompatActivity6import io.reactivex.rxjava3.android.schedulers.AndroidSchedulers7import io.reactivex.rxjava3.core.CompletableObserver8import io.reactivex.rxjava3.core.Observable9import io.reactivex.rxjava3.core.Observer10import io.reactivex.rxjava3.core.SingleObserver11import io.reactivex.rxjava3.disposables.Disposable12import io.reactivex.rxjava3.schedulers.Schedulers13import kotlinx.coroutines.GlobalScope14import kotlinx.coroutines.delay15import kotlinx.coroutines.launch16import timber.log.Timber17class MainActivity : AppCompatActivity() {18    override fun onCreate(savedInstanceState: Bundle?) {19        super.onCreate(savedInstanceState)20        setContentView(R.layout.activity_main)21        if (checkSelfPermission(Manifest.permission.WRITE_EXTERNAL_STORAGE) != PackageManager.PERMISSION_GRANTED) {22            requestPermissions(arrayOf(Manifest.permission.WRITE_EXTERNAL_STORAGE), 1000)23            return24        }25        testThreads()26    }27    override fun onRequestPermissionsResult(requestCode: Int, permissions: Array<out String>, grantResults: IntArray) {28        super.onRequestPermissionsResult(requestCode, permissions, grantResults)29        testThreads()30    }31    private fun testThreads() {32        Timber.plant(CustomLog())33        wait(5) {34            coroutinesTest()35            runnableTest()36            threadTest()37        }38        whoIsFirst { result ->39            Timber.d("MainActivity_TAG: onCreate: $result")40        }41        rxJavaTest()42    }43    private fun threadTest() {44        Timber.d("MainActivity_TAG: threadTest: ")45        for (i in 1..10) {46            Thread {47                Timber.d("MainActivity_TAG: threadTest: Thread $i")48            }.start()49        }50    }51    private fun runnableTest() {52        Timber.d("MainActivity_TAG: runnableTest: ")53        for (i in 1..10) {54            Runnable {55                Timber.d("MainActivity_TAG: runnableTest: Runnable $i")56            }.run()57        }58    }59    private fun coroutinesTest() {60        Timber.d("MainActivity_TAG: coroutinesTest: ")61        for (i in 1..10) {62            GlobalScope.launch {63                Timber.d("MainActivity_TAG: coroutinesTest: coroutine $i")64            }65        }66    }67    private fun wait(seconds: Int, onDone: () -> Unit) = GlobalScope.launch {68        Timber.d("MainActivity_TAG: wait: $seconds seconds")69        delay((seconds * 1000).toLong())70        onDone()71    }72    private fun whoIsFirst(myOnDoneFunction: (String) -> Unit) = GlobalScope.launch {73        var place = 074        Thread {75            place++76            myOnDoneFunction("Thread Finished: $place")77        }.start()78        Runnable {79            place++80            myOnDoneFunction("Runnable Finished: $place")81        }.run()82        GlobalScope.launch {83            place++84            myOnDoneFunction("CoRoutines Finished: $place")85        }86    }87    private fun rxJavaTest() {88        Timber.d("MainActivity_TAG: rxJavaTest: ")89        Observable.just("one", "two", "three", "four", "five")90            .subscribeOn(Schedulers.io())91            .observeOn(AndroidSchedulers.mainThread())92            .doAfterNext {93                Timber.d("MainActivity_TAG: rxJavaTest: doAfterNext: $it")94            }95            .skip(3)96            .subscribe(object: Observer<String>{97                override fun onComplete() {98                    Timber.d("MainActivity_TAG: onComplete: ")99                }100                override fun onSubscribe(d: Disposable?) {101                    Timber.d("MainActivity_TAG: onSubscribe: ")102                }103                override fun onNext(t: String?) {104                    Timber.d("MainActivity_TAG: onNext: $t")105                }106                override fun onError(e: Throwable?) {107                    Timber.d("MainActivity_TAG: onError: ")108                }109            })110    }111}...

StatTest.kt

Source:StatTest.kt

1package studio.forface.covid.domain.entity2import com.soywiz.klock.DateTime3import com.soywiz.klock.hours4import kotlinx.coroutines.test.runBlockingTest5import studio.forface.covid.test.CoroutinesTest6import studio.forface.covid.test.coroutinesTest7import kotlin.test.Test8import kotlin.test.assertEquals9/**10 * __Unit__ test suite for [Stat]11 * @author Davide Farella12 */13internal class StatTest : CoroutinesTest by coroutinesTest {14    @Test15    fun `diff works correctly with updated stats`() = runBlockingTest {16        // GIVEN17        val now = DateTime.now()18        val stats = listOf(19            Stat(99, 44, 65, now),20            Stat(75, 40, 63, now - 3.hours),21            Stat(72, 39, 53, now - 6.hours),22            Stat(60, 22, 51, now - 9.hours),23            Stat(54, 14, 20, now - 12.hours),24            Stat(41, 10, 16, now - 15.hours)25        )26        // WHEN27        val diff1 = stats % 4.hours...

CoroutineOne.kt

Source:CoroutineOne.kt

...8    }9    private fun setView() {10        GlobalScope.launch(Dispatchers.Main) {11            try {12                //Log.d("CoroutinesTest:", fun1())13                Log.d("CoroutinesTest:", fun2())14                fun21()15                Log.d("CoroutinesTest:", fun3())16                fun31()17                Log.d("CoroutinesTest:", fun4())18                Log.d("CoroutinesTest:", "finished")19            } catch (e: Exception) {20                e.printStackTrace()21            } finally {22                Log.d("CoroutinesTest:", "finally printed")23            }24        }25    }26    private fun setView2() {27        Coroutines.main {28            try {29                Log.d("CoroutinesTest:", fun1())30                Log.d("CoroutinesTest:", fun2())31                Log.d("CoroutinesTest:", fun3())32                Log.d("CoroutinesTest:", "finished")33            } catch (c: Exception) {34            } finally {35                Log.d("CoroutinesTest:", "printed")36            }37        }38    }39    private suspend fun fun1(): String {40        delay(2000)41        return "Test 1"42    }43    private suspend fun fun2(): String {44        withContext(Dispatchers.IO) {45            delay(2000)46        }47        return "Test 2"48    }49    private suspend fun fun21() {50        withContext(Dispatchers.Main) {51            delay(2000)52            Log.d("CoroutinesTest:", "fun21")53        }54    }55    private suspend fun fun3(): String {56        withContext(Dispatchers.Main) {57            delay(4000)58        }59        return "Test 3"60    }61    private suspend fun fun31(): String {62        GlobalScope.launch(Dispatchers.Main) {63            delay(4000)64        }65        return "Test 3"66    }...

CoroutinesTCKTest.kt

Source:CoroutinesTCKTest.kt

1/*2 * Copyright 2019 Red Hat, Inc.3 *4 * All rights reserved. This program and the accompanying materials5 * are made available under the terms of the Eclipse Public License v1.06 * and Apache License v2.0 which accompanies this distribution.7 *8 * The Eclipse Public License is available at9 * http://www.eclipse.org/legal/epl-v10.html10 *11 * The Apache License v2.0 is available at12 * http://www.opensource.org/licenses/apache2.0.php13 *14 * You may elect to redistribute this code under either of these licenses.15 */16package io.vertx.lang.kotlin.test17import io.vertx.codegen.testmodel.TestInterface18import io.vertx.codegen.testmodel.TestInterfaceImpl19import io.vertx.kotlin.codegen.testmodel.methodWithHandlerAsyncResultStringAwait20import kotlinx.coroutines.Dispatchers21import kotlinx.coroutines.GlobalScope22import kotlinx.coroutines.async23import org.junit.Assert.fail24import org.junit.Test25import kotlin.test.assertEquals26/**27 * @author <a href="mailto:julien@julienviet.com">Julien Viet</a>28 */29class CoroutinesTCKTest {30  private val tck: TestInterface = TestInterfaceImpl()31  @Test32  fun testAsyncResultSuccess() {33    val s = coroutinesTest { tck.methodWithHandlerAsyncResultStringAwait(false) }34    assertEquals("quux!", s)35  }36  @Test37  fun testAsyncResultFailure() {38    try {39      coroutinesTest { tck.methodWithHandlerAsyncResultStringAwait(true) }40      fail()41    } catch (e: Exception) {42      assertEquals("foobar!", e.message)43    }44  }45  private fun <T> coroutinesTest(block: suspend () -> T) : T {46    val deferred = GlobalScope.async(Dispatchers.Unconfined) {47      block()48    }49    return deferred.getCompleted()50  }51}...

CommonUtilsTest.kt

Source:CommonUtilsTest.kt

1package studio.forface.covid.domain.util2import kotlinx.coroutines.test.runBlockingTest3import kotlinx.coroutines.withTimeoutOrNull4import studio.forface.covid.test.CoroutinesTest5import studio.forface.covid.test.assertBetween6import studio.forface.covid.test.coroutinesTest7import kotlin.test.Test8import kotlin.time.milliseconds9internal class CommonUtilsTest : CoroutinesTest by coroutinesTest {10    @Test11    fun `repeatCatching runs correctly`() = runBlockingTest {12        // GIVEN13        val totalRunTime = 5014        val refreshInterval = 115        val errorInterval = 516        val errorEvery = 317        var count = 018        val block = { i: Int ->19            count = i20            // Throw exception every 3 iterations for verify error interval21            if (i % errorEvery == 0) throw IllegalStateException()22        }23        // WHEN...

TestDependencies.kt

Source:TestDependencies.kt

1object TestDependencies {2    private const val junit = "junit:junit:${Versions.junit}"3    private const val mockitoKotlin = "com.nhaarman.mockitokotlin2:mockito-kotlin:${Versions.mockito}"4    private const val mockitoCore = "org.mockito:mockito-core:${Versions.mockitoCore}"5    private const val coroutinesTest = "org.jetbrains.kotlinx:kotlinx-coroutines-test:${Versions.coroutinesTest}"6    private const val coreTesting = "androidx.arch.core:core-testing:${Versions.coreTesting}"7    private const val mockWebServer = "com.squareup.okhttp3:mockwebserver:${Versions.mockWebServer}"8    private const val roomTest = "androidx.room:room-testing:${Versions.room}"9    val testLibraries = arrayListOf<String>().apply {10        add(junit)11        add(mockitoKotlin)12        add(mockitoCore)13        add(coroutinesTest)14        add(coreTesting)15        add(mockWebServer)16        add(roomTest)17    }18}...

CoroutinesTest.kt

Source:CoroutinesTest.kt

...5import kotlinx.coroutines.test.resetMain6import kotlinx.coroutines.test.setMain7import kotlin.test.AfterTest8import kotlin.test.BeforeTest9interface CoroutinesTest {10    val mainThreadSurrogate: ExecutorCoroutineDispatcher11    @BeforeTest12    fun setUp() {13        Dispatchers.setMain(mainThreadSurrogate)14    }15    @AfterTest16    fun tearDown() {17        Dispatchers.resetMain() // reset main dispatcher to the original Main dispatcher18        mainThreadSurrogate.close()19    }20}21val coroutinesTest get() = object : CoroutinesTest {22    override val mainThreadSurrogate = newSingleThreadContext("UI thread")23}...

CoroutinesTest

Using AI Code Generation

1@RunWith(AndroidJUnit4::class)2class MainActivityTest {3    val activityRule = ActivityScenarioRule(MainActivity::class.java)4    fun test_isActivityInView() {5        onView(withId(R.id.main)).check(matches(isDisplayed()))6    }7    fun test_visibility_title_nextButton() {8        onView(withId(R.id.activity_main_title)).check(matches(isDisplayed()))9        onView(withId(R.id.button_next_activity)).check(matches(isDisplayed()))10    }11    fun test_isTitleTextDisplayed() {12        onView(withId(R.id.activity_main_title)).check(matches(withText(R.string.text_mainactivity)))13    }14    fun test_navSecondaryActivity() {15        onView(withId(R.id.button_next_activity)).perform(click())16        onView(withId(R.id.secondary)).check(matches(isDisplayed()))17    }18}19fun test_isTitleTextDisplayed() {20    onView(withId(R.id.activity_main_title)).check(matches(withText(R.string.text_mainactivity)))21}22at dalvik.system.VMStack.getThreadStackTrace(Native Method)23at java.lang.Thread.getStackTrace(Thread.java:1538)24at androidx.test.espresso.base.DefaultFailureHandler.getUserFriendlyError(DefaultFailureHandler.java:91)25at androidx.test.espresso.base.DefaultFailureHandler.handle(DefaultFailureHandler.java:55)26at androidx.test.espresso.ViewInteraction.waitForAndHandleInteractionResults(ViewInteraction.java:312)27at androidx.test.espresso.ViewInteraction.check(ViewInteraction.java:297)28at com.example.android.testing.espresso.BasicSample.MainActivityTest.test_isTitleTextDisplayed(MainActivityTest.kt:48)29at java.lang.reflect.Method.invoke(Native Method)30at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)31at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)32at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod

CoroutinesTest

Using AI Code Generation

1@RunWith(JUnit4::class)2class CoroutinesTestRule(private val testDispatcher: TestCoroutineDispatcher = TestCoroutineDispatcher()) :3    TestWatcher() {4    val testCoroutineScope = TestCoroutineScope(testDispatcher)5    override fun starting(description: Description?) {6        super.starting(description)7        Dispatchers.setMain(testDispatcher)8    }9    override fun finished(description: Description?) {10        super.finished(description)11        Dispatchers.resetMain()12        testCoroutineScope.cleanupTestCoroutines()13    }14}15val coroutinesTestRule = CoroutinesTestRule()16fun `test function`() = testCoroutineScope.runBlockingTest {17}18fun `test function`() {19    val testDispatcher = TestCoroutineDispatcher()20    val testScope = TestCoroutineScope(testDispatcher)21    testScope.runBlockingTest {22    }23}24fun `test function`() {25    val testScope = TestCoroutineScope()26    testScope.runBlockingTest {27    }28}29fun `test function`() {30    val testExceptionHandler = TestCoroutineExceptionHandler()31    val testScope = TestCoroutineScope(testExceptionHandler)32    testScope.runBlockingTest {33    }34}35fun `test function`() {36    val testDispatcher = TestCoroutineDispatcher()37    val testExceptionHandler = TestCoroutineExceptionHandler()38    val testScope = TestCoroutineScope(testDispatcher + testExceptionHandler)39    testScope.runBlockingTest {40    }41}42fun `test function`() {43    val testDispatcher = TestCoroutineDispatcher()

CoroutinesTest

Using AI Code Generation

1@RunWith(AndroidJUnit4::class)2class MainActivityTest {3    val instantTaskExecutorRule = InstantTaskExecutorRule()4    val mainActivityTestRule = ActivityScenarioRule(MainActivity::class.java)5    val coroutineTestRule = CoroutineTestRule()6    fun testLaunchFragment() {7        onView(withId(R.id.nav_host_fragment)).check(matches(isDisplayed()))8    }9    fun testLaunchFragmentWithCoroutine() {10        coroutineTestRule.testDispatcher.runBlockingTest {11            onView(withId(R.id.nav_host_fragment)).check(matches(isDisplayed()))12        }13    }14}

CoroutinesTest

Using AI Code Generation

1@RunWith(AndroidJUnit4::class)2class CoroutinesTest {3    private val testDispatcher = TestCoroutineDispatcher()4    private val testScope = TestCoroutineScope(testDispatcher)5    var instantTaskExecutorRule = InstantTaskExecutorRule()6    fun setup() {7        Dispatchers.setMain(testDispatcher)8    }9    fun tearDown() {10        Dispatchers.resetMain()11        testScope.cleanupTestCoroutines()12    }13    fun testCoroutine() = testScope.runBlockingTest {14        val viewModel = MainViewModel()15        viewModel.getData()16        delay(2000)17        Assert.assertEquals("Kotlin", viewModel.data.value)18    }19}20@RunWith(AndroidJUnit4::class)21class LiveDataTestUtilTest {22    var instantTaskExecutorRule = InstantTaskExecutorRule()23    fun testLiveData() {24        val liveData = MutableLiveData<String>()25        val observer = mock<Observer<String>>()26        liveData.observeForever(observer)27        verify(observer).onChanged("Kotlin")28    }29}30@RunWith(AndroidJUnit4::class)31class ViewModelTest {32    private val testDispatcher = TestCoroutineDispatcher()33    private val testScope = TestCoroutineScope(testDispatcher)34    var instantTaskExecutorRule = InstantTaskExecutorRule()35    fun setup() {36        Dispatchers.setMain(testDispatcher)37    }38    fun tearDown() {39        Dispatchers.resetMain()40        testScope.cleanupTestCoroutines()41    }42    fun testViewModel() = testScope.runBlockingTest {43        val viewModel = MainViewModel()44        val observer = mock<Observer<String>>()45        viewModel.data.observeForever(observer)46        viewModel.getData()

CoroutinesTest

Using AI Code Generation

1@RunWith(AndroidJUnit4::class)2class CoroutinesTest {3    val testCoroutineRule = TestCoroutineRule()4    fun testCoroutine() {5        testCoroutineRule.runBlockingTest {6            delay(1000)7            assertTrue(true)8        }9    }10}11class TestCoroutineRule : TestWatcher() {12    val testDispatcher = TestCoroutineDispatcher()13    override fun starting(description: Description?) {14        super.starting(description)15        Dispatchers.setMain(testDispatcher)16    }17    override fun finished(description: Description?) {18        super.finished(description)19        Dispatchers.resetMain()20        testDispatcher.cleanupTestCoroutines()21    }22    fun runBlockingTest(block: suspend TestCoroutineScope.() -> Unit) =23        testDispatcher.runBlockingTest { block() }24}25class TestCoroutineDispatcher : CoroutineDispatcher(), Delay {26    private val testCoroutineScope = TestCoroutineScope()27    override fun dispatch(context: CoroutineContext, block: Runnable) {28        testCoroutineScope.launch { block.run() }29    }30    override fun scheduleResumeAfterDelay(31    ) {32        testCoroutineScope.advanceTimeBy(timeMillis)33    }34    fun cleanupTestCoroutines() = testCoroutineScope.cleanupTestCoroutines()35}36class TestCoroutineScope : CoroutineScope {37    val testCoroutineDispatcher = TestCoroutineDispatcher()38    private val job = Job()39        get() = job + testCoroutineDispatcher40    fun cleanupTestCoroutines() {41        job.cancel()42    }43}44class TestCoroutineScope : CoroutineScope {45    val testCoroutineDispatcher = TestCoroutineDispatcher()46    private val job = Job()47        get() = job + testCoroutineDispatcher48    fun cleanupTestCoroutines() {49        job.cancel()50    }51}52class TestCoroutineScope : CoroutineScope {53    val testCoroutineDispatcher = TestCoroutineDispatcher()54    private val job = Job()55        get() = job + testCoroutineDispatcher56    fun cleanupTestCoroutines() {57        job.cancel()58    }59}60class TestCoroutineScope : CoroutineScope {

CoroutinesTest

Using AI Code Generation

1@RunWith(RobolectricTestRunner::class)2@Config(manifest = Config.NONE)3class TestCoroutineRuleTest {4    val testCoroutineRule = TestCoroutineRule()5    fun `test coroutine`() = testCoroutineRule.runBlockingTest {6    }7}

CoroutinesTest

Using AI Code Generation

1@RunWith(AndroidJUnit4::class)2class MyViewModelTest {3    val instantExecutorRule = InstantTaskExecutorRule()4    val mainCoroutineRule = MainCoroutineRule()5    val hiltRule = HiltAndroidRule(this)6    val hiltAndroidTestRule = HiltAndroidTestRule(this)7    fun setup() {8        hiltAndroidTestRule.inject()9        MockKAnnotations.init(this)10    }11    fun testMyViewModel() {12        mainCoroutineRule.runBlockingTest {13            val myViewModel = MyViewModel(myRepository)14            val myData = MyData("MyData")15            coEvery { myRepository.getMyData() } returns myData16            myViewModel.getMyData()17            Assert.assertEquals(myViewModel.myData.getOrAwaitValue(), myData)18        }19    }20}21class MainCoroutineRule(val dispatcher: TestCoroutineDispatcher = TestCoroutineDispatcher()) :22    TestWatcher() {23    override fun starting(description: Description?) {24        super.starting(description)25        Dispatchers.setMain(dispatcher)26    }27    override fun finished(description: Description?) {28        super.finished(description)29        Dispatchers.resetMain()30        dispatcher.cleanupTestCoroutines()31    }32    fun runBlockingTest(block: suspend TestCoroutineScope.() -> Unit) =33        dispatcher.runBlockingTest {34            block()35        }36}37class InstantTaskExecutorRule : TestWatcher() {38    override fun starting(description: Description?) {39        super.starting(description)40        InstantTaskExecutorRule().apply {

Automation Testing Tutorials

Learn to execute automation testing from scratch with LambdaTest Learning Hub. Right from setting up the prerequisites to run your first automation test, to following best practices and diving deeper into advanced test scenarios. LambdaTest Learning Hubs compile a list of step-by-step guides to help you be proficient with different test automation frameworks i.e. Selenium, Cypress, TestNG etc.