#目次
- Kotlin Flow とは
- サンプルコード
- まとめ
##1. Kotlin Flow とは
suspend funは、返す値が1つのみで、Flowは、複数の値を順に出力することができることが、大きな違いである。リアルタイムで、更新処理を行いたい場合に有効である。(UI の状態が変化したときに、変更を受け取る等)
また、Flowは、suspend funを使うことで、メインスレッドを妨げることなく、ネットワークリクエストを行える。
Flowは、大きく分けて3つの役割を持っています。
・プロデューサ‥非同期に出力する値の作成を行う
・インターミディアリ‥出力されたデータに変更を加えることができる
・コンシューマ‥得られた出力値を利用する
Repository,ViewModelに当てはめると、出力値の作成をRepositoryで行い、使いやすい状態に変換する(mapで、リストの中身を置き換えるなど)、次に、得られた出力値を適切なスコープで呼び出し、UInへと反映させる役割を、ViewModelが持つ。という風に、解釈しています。
それでは、サンプルコードを説明します。
##2. サンプルコード
サンプルに使用するコードは、GithubのRepositoryを検索クエリを用いて、一覧を表示するというものになっています。
使用したいAPIを、以下のように定義します。
interface GithubApi {
@GET("repositories?")
suspend fun searchGithubRepository(@Query("q") query: String): ApiResult
}
次に、プロデューサ、インターミディアリの役割を持ったRepository層からです。
class SearchRepository {
fun searchGithubRepository(query: String): Flow<List<DetailItem>> = flow<List<DetailItem>> {
// List<DetailItem>>形式に変換
val detailItemList = RetrofitInstance.githubApi.searchGithubRepository(query).items.map{ it.toDetailItem() }
emit(detailItemList)
Log.d("API Call", "called API")
}.flowOn(Dispatchers.IO)
}
ここで、重要になってくるのが、flowOn(スレッドを指定する)、mapです。
まずは、簡単なmapの説明から、このmapを使えることは、Flowを利用する点で非常に便利だなと感じる点の一つです。それでは、説明に移ります。
ここでは、Flowを使って、List< DetailItem >形式に変換したいと考えています。ですが、使用したいAPIのレスポンスをインターフェースから確認すると、ApiResultクラスであることから、このままでは求める形式のオブジェクトを得ることができません。
そこで、Flow(プロデューサ)によって出力された出力値に、mapでDetailItemへ変更を加えることで利用したい、List< DetailItem >へ変換することができました。
適切にオブジェクトを変換し、出力できるFlowの威力が伝わったかと思います。
次に、flowOn()です。コンシューマに影響を与えずに、プロデューサのCoroutineContextを変更できる中間演算子のことです。Repository層の処理を、最終的にviewModelScope内で起動する必要があり、これはUIスレッド(メインスレッド)であり、このスレッドでオペレショーンを行うとクラッシュ、フリーズなどの原因になります。そこで、viewModelScope内で呼び出すが、実際はIOスレッドで呼び出されているという風に、flowOn()を用いて行うことができます。つまり、collectを行う、コルーチンのスコープでプロデューサが実行されているようにみえるが、実際は、別のCoroutineContextを利用していることでスレッドの問題が発生しないことがわかる。
最後に、出力された結果を収集するコンシューマであるViewModelの説明に移ります。
class SearchViewModel(
private val searchRepository: SearchRepository
) : ViewModel() {
private val _searchResult: MutableStateFlow<Result> = MutableStateFlow(Result.Idle)
val searchResult: StateFlow<Result> = _searchResult
// Avoid using GlobalScope
// Flow の例外キャッチを、catch を用いて行う
fun searchGithubRepository(query: String) = viewModelScope.launch {
_searchResult.value = Result.Loading
searchRepository.searchGithubRepository(query)
.catch { e ->
_searchResult.value = Result.Error(e.toString())
}.collect {
data ->
_searchResult.value = Result.Success(data)
}
}
}
viewModelScope(Dispatchers.Main)UIスレッドで、コルーチンを起動し、collectしていることがわかります。
ここで、注目する点として例外のキャッチ方法、収集方法です。
まず、キャッチ方法から、中間演算子catchを呼び出すことで、処理中の例外をキャッチすることができます。ここでは、sealed classを用いて、例外が発生したときにその内容をキャッチし、状態を保持するような処理を記述しています。
そして、collectです。これを、viewModelScopeで呼び出すことで、UIスレッドの変更を読み取ることができ、viewの更新を行うことができます。
3. まとめ
Flowを用いてAPIの呼び出しを実装してみました。ざっくりとしか理解ができていない部分があるので、深堀をやっていきます。