Kotlin Academy · Pelajaran

Menguji StateFlow dan SharedFlow dengan Turbine

Tulis ujian unit untuk keadaan berasaskan Flow menggunakan pustaka pengujian Turbine.

Pelajaran 4 daripada 414 langkah

Menguji StateFlow dan SharedFlow dengan Turbine ialah pelajaran Kotlin Academy percuma di CoddyKit. Ini ialah pelajaran 4 daripada 4. Sebanyak 3 pelajaran dalam laluan pembelajaran ini boleh dibaca sepenuhnya secara percuma — selepas itu, CoddyKit PRO membuka akses kepada semua pelajaran, serta latihan praktikal dengan penyunting kod terbina dalam dan tutor kecerdasan buatan yang tersedia 24/7. Pelajaran ini merupakan sebahagian daripada laluan pembelajaran Kotlin Academy, dan kemajuan anda disegerakkan merentas web serta aplikasi CoddyKit. Kursus Kotlin Academy merangkumi sejumlah 4 pelajaran.

Mengapa Turbine?

Turbine ialah pustaka pengujian untuk Kotlin Flow yang memudahkan pengesahan emisi. Tanpanya, pengujian aliran memerlukan pengumpulan saluran secara manual dengan had masa.

// Add to test dependencies:
// testImplementation("app.cash.turbine:turbine:1.0.0")
// testImplementation("org.jetbrains.kotlinx:kotlinx-coroutines-test:1.7.3")
import app.cash.turbine.*
import kotlinx.coroutines.flow.*
import kotlinx.coroutines.test.*
fun main() { println("Turbine + runTest = clean flow testing") }

Pengujian Aliran Asas dengan test()

flow.test { } mengumpulkan aliran dan membolehkan anda mengesahkan setiap emisi menggunakan awaitItem(), awaitComplete() dan awaitError().

import app.cash.turbine.*
import kotlinx.coroutines.flow.*
import kotlinx.coroutines.test.*
fun testBasicFlow() = runTest {
    val flow = flowOf(1, 2, 3)
    flow.test {
        assertEquals(1, awaitItem())
        assertEquals(2, awaitItem())
        assertEquals(3, awaitItem())
        awaitComplete()
    }
}

Menguji StateFlow

StateFlow sentiasa mengeluarkan nilai semasanya apabila dikumpulkan. awaitItem() Turbine menangkap emisi awal tersebut.

import app.cash.turbine.*
import kotlinx.coroutines.flow.*
import kotlinx.coroutines.test.*
fun testStateFlow() = runTest {
    val state = MutableStateFlow("loading")
    state.test {
        assertEquals("loading", awaitItem())  // initial value
        state.value = "success"
        assertEquals("success", awaitItem())
        cancelAndIgnoreRemainingEvents()
    }
}

Menguji Peristiwa SharedFlow

SharedFlow dengan replay=0 hanya mengeluarkan peristiwa akan datang. Mulakan pengumpulan dahulu, kemudian lakukan emisi.

import app.cash.turbine.*
import kotlinx.coroutines.flow.*
import kotlinx.coroutines.test.*
fun testSharedFlow() = runTest {
    val events = MutableSharedFlow<String>()
    events.test {
        events.emit("LoginSuccess")
        assertEquals("LoginSuccess", awaitItem())
        events.emit("Navigate")
        assertEquals("Navigate", awaitItem())
        cancelAndIgnoreRemainingEvents()
    }
}

runTest untuk Masa Maya

runTest menggunakan masa maya — panggilan delay() memajukan masa maya serta-merta, menjadikan ujian yang melibatkan kelewatan lebih pantas.

import kotlinx.coroutines.flow.*
import kotlinx.coroutines.test.*
import app.cash.turbine.*
fun testDelayedFlow() = runTest {
    val flow = flow {
        delay(1000)  // virtual — runs instantly
        emit("done")
    }
    flow.test {
        assertEquals("done", awaitItem())
        awaitComplete()
    }
}

awaitError untuk Pengujian Pengecualian

awaitError() mengesahkan bahawa aliran tamat dengan pengecualian. Gunakannya bersama jenis pengecualian yang dijangka.

import app.cash.turbine.*
import kotlinx.coroutines.flow.*
import kotlinx.coroutines.test.*
fun testFlowError() = runTest {
    val flow = flow {
        emit(1)
        throw RuntimeException("stream error")
    }
    flow.test {
        assertEquals(1, awaitItem())
        val error = awaitError()
        assertEquals("stream error", error.message)
    }
}

expectNoEvents dan cancelAndIgnoreRemainingEvents

expectNoEvents() mengesahkan bahawa tiada apa-apa yang diemisi. cancelAndIgnoreRemainingEvents() membatalkan pengumpulan dan mengabaikan emisi yang masih menunggu.

import app.cash.turbine.*
import kotlinx.coroutines.flow.*
import kotlinx.coroutines.test.*
fun testNoEvents() = runTest {
    val flow = MutableSharedFlow<Int>()
    flow.test {
        expectNoEvents()  // nothing emitted yet
        flow.emit(1)
        assertEquals(1, awaitItem())
        cancelAndIgnoreRemainingEvents()
    }
}

Menguji ViewModel dengan Turbine

Uji StateFlow ViewModel dengan menyuntik repositori palsu dan mengesahkan peralihan keadaan.

import app.cash.turbine.*
import kotlinx.coroutines.flow.*
import kotlinx.coroutines.test.*
sealed class State { object Loading : State(); data class Data(val v: String) : State() }
class FakeRepo { suspend fun fetch() = "result" }
class VM(repo: FakeRepo, scope: kotlinx.coroutines.CoroutineScope) {
    private val _s = MutableStateFlow<State>(State.Loading)
    val state = _s.asStateFlow()
    init { scope.launch { _s.value = State.Data(repo.fetch()) } }
}
fun testVM() = runTest {
    val vm = VM(FakeRepo(), backgroundScope)
    vm.state.test {
        assertEquals(State.Loading, awaitItem())
        val data = awaitItem() as State.Data
        assertEquals("result", data.v)
        cancelAndIgnoreRemainingEvents()
    }
}

Beberapa Pengumpul dengan turbineScope

turbineScope { } membolehkan anda menguji beberapa aliran secara serentak, setiap satunya dengan tika Turbine tersendiri.

import app.cash.turbine.*
import kotlinx.coroutines.flow.*
import kotlinx.coroutines.test.*
fun testMultipleFlows() = runTest {
    val a = MutableStateFlow(1)
    val b = MutableStateFlow("x")
    turbineScope {
        val aTurbine = a.testIn(backgroundScope)
        val bTurbine = b.testIn(backgroundScope)
        assertEquals(1, aTurbine.awaitItem())
        assertEquals("x", bTurbine.awaitItem())
        a.value = 2
        assertEquals(2, aTurbine.awaitItem())
        aTurbine.cancelAndIgnoreRemainingEvents()
        bTurbine.cancelAndIgnoreRemainingEvents()
    }
}

Menguji Operator Aliran

Uji tingkah laku operator aliran tersuai dan transformasi secara berasingan menggunakan Turbine.

import app.cash.turbine.*
import kotlinx.coroutines.flow.*
import kotlinx.coroutines.test.*
fun testOperators() = runTest {
    (1..5).asFlow()
        .filter { it % 2 == 0 }
        .map { it * 10 }
        .test {
            assertEquals(20, awaitItem())
            assertEquals(40, awaitItem())
            awaitComplete()
        }
}

Menguji dengan Pemajuan Masa Palsu

Gunakan testScheduler.advanceTimeBy() untuk mengawal masa maya dengan tepat dalam ujian yang melibatkan delay.

import app.cash.turbine.*
import kotlinx.coroutines.flow.*
import kotlinx.coroutines.test.*
fun testTimedFlow() = runTest {
    val flow = flow {
        emit("start")
        delay(500)
        emit("end")
    }
    flow.test {
        assertEquals("start", awaitItem())
        testScheduler.advanceTimeBy(500)
        assertEquals("end", awaitItem())
        awaitComplete()
    }
}

Kesilapan Biasa

Sentiasa batalkan Turbine pada akhir ujian aliran panas. Terlupa memanggil cancelAndIgnoreRemainingEvents() menyebabkan ujian tergantung kerana menunggu peristiwa lain.

import app.cash.turbine.*
import kotlinx.coroutines.flow.*
import kotlinx.coroutines.test.*
fun testGoodPractice() = runTest {
    val state = MutableStateFlow(0)
    state.test {
        awaitItem()  // initial 0
        state.value = 1
        awaitItem()  // 1
        // Always cancel hot flows:
        cancelAndIgnoreRemainingEvents()
    }
}

Semakan Pantas

Fungsi Turbine manakah yang mengumpulkan item yang diemisi seterusnya dan melontarkan pengecualian jika aliran selesai atau mengalami ralat terlebih dahulu?

Jawab dalam pelajaran interaktif

Ringkasan

Turbine memudahkan pengujian Flow dengan awaitItem(), awaitComplete() dan awaitError(). Gunakan runTest untuk masa maya. Sentiasa batalkan ujian aliran panas dengan cancelAndIgnoreRemainingEvents().

Percuma untuk bermula

Pelajari Kotlin dengan tutor kecerdasan buatan — percuma

Tulis dan jalankan kod sebenar dalam pelayar anda, dapatkan bantuan segera daripada tutor kecerdasan buatan yang tersedia 24/7, dan sambung semula dari tempat anda berhenti di web atau dalam aplikasi.

Kursus: 51
Pelajaran: 203

Mula belajar secara percuma Lihat kursus penuh

Soalan Lazim

Adakah pelajaran “Menguji StateFlow dan SharedFlow dengan Turbine” percuma?

Ya — sebanyak 3 pelajaran dalam laluan pembelajaran Kotlin Academy, termasuk “Menguji StateFlow dan SharedFlow dengan Turbine”, boleh dibaca sepenuhnya secara percuma di web ini. Selepas itu, CoddyKit PRO membuka akses kepada semua pelajaran, serta latihan interaktif dengan penyunting kod terbina dalam dan tutor kecerdasan buatan yang tersedia 24/7. Kursus Kotlin Academy merangkumi sejumlah 4 pelajaran.

Apakah yang akan saya pelajari dalam “Menguji StateFlow dan SharedFlow dengan Turbine”?

Tulis ujian unit untuk keadaan berasaskan Flow menggunakan pustaka pengujian Turbine. Anda berlatih Kotlin Academy menggunakan kod praktikal yang dijalankan terus dalam pelayar, manakala tutor kecerdasan buatan 24/7 menjawab soalan anda semasa anda mengikuti pelajaran.

Adakah saya memerlukan pengalaman untuk memulakan Kotlin Academy?

Tiada pengalaman terdahulu diperlukan. Pembelajaran Kotlin Academy di CoddyKit disusun untuk pelajar daripada peringkat pemula hingga lanjutan, jadi anda boleh bermula di sini atau dari awal dan belajar mengikut kadar anda sendiri. Ini ialah pelajaran 4 daripada 4.

Berapa lamakah pelajaran “Menguji StateFlow dan SharedFlow dengan Turbine” diambil?

Kebanyakan pelajaran CoddyKit mengambil masa kira-kira 5–10 minit. Setiap pelajaran ringkas dan interaktif, jadi anda boleh membuat kemajuan secara berterusan dan menyambung tepat dari tempat anda berhenti di web atau aplikasi.

Bolehkah saya menulis dan menjalankan kod dalam pelajaran Kotlin Academy ini?

Ya. Setiap pelajaran Kotlin Academy menyertakan penyunting kod terbina dalam, jadi anda boleh menulis dan menjalankan kod sebenar terus dalam pelayar serta menerima maklum balas kecerdasan buatan serta-merta — tanpa memerlukan persediaan setempat.

Semua pelajaran dalam kursus ini

StateFlow: Pemegang Keadaan Aktif untuk UI
SharedFlow: Bas Peristiwa dan Peristiwa Sekali Lalu
Menukar Flow Sejuk kepada Aktif dengan shareIn dan stateIn
Menguji StateFlow dan SharedFlow dengan Turbine

← Kembali ke Kotlin Academy