kotlin-coroutines-flows

Topics in the source

• Kotlin コルーチン & Flow
• アクティベートするタイミング
• 構造化並行性
• スコープ階層
• 並列分解
• SupervisorScope
• Flow パターン
• コールドフロー — ワンショットからストリームへの変換

Android および Kotlin Multiplatform プロジェクトにおける構造化並行性、Flow ベースのリアクティブストリーム、コルーチンテストのパターン。 Kotlin コルーチンで非同期コードを書く リアクティブデータに Flow、StateFlow、または SharedFlow を使用する 並行操作を処理する（並列読み込み、デバウンス、リトライ） コルーチンと Flow をテストする コルーチンスコープとキャンセルを管理する 常に構造化並行性を使用してください — GlobalScope は絶対に使わない: 並列作業には coroutineScope + async を使用: 子の失敗が兄弟をキャンセルしてはならない場合は supervisorScope を使用: WhileSubscribed(5000) は最後のサブスクライバーが離れてから 5 秒間アップストリームをアクティブに保ちます — 設定変更を再起動なしに生き延びます。 KMP では Dispatchers.Default と Dispatchers.Main（すべてのプラットフォームで利用可能）を使用してください。Dispatchers.IO は JVM/Android のみです — 他のプラットフォームでは Dispatchers.Default を使用するか DI で提供してください。 長時間実行されるループはキャンセルを確認する必要があります: GlobalScope の使用 — コルーチンがリークし、構造化キャンセルがない スコープなしで init {} 内で Flow をコレクトする — viewModelScope.launch を使用 ミュータブルコレクションで MutableStateFlow を使用する — 常にイミュータブルコピーを使用: state.update { it.copy(list = it.list + newItem) } CancellationException をキャッチする — 適切なキャンセルのために伝播させる コレクトするために flowOn(Dispatchers.Main) を使用する — コレクションディスパッチャーは呼び出し元のディスパッチャー remember なしで @Composable 内に Flow を作成する — 再コンポジションのたびにフローが再作成される スキル: compose-multiplatform-patterns で Flow の UI 消費を参照。 スキル: android-clean-architecture でレイヤーにおけるコルーチンの役割を参照。