部屋のデータベースからエピソードの流れがあります。この流れはライブデータとして問題なく観測できます。
しかし、ユーザーがボタンをクリックしたときに、このフローから最後の値を読み取りたいとも考えています。first() ターミナル フロー演算子を試しましたが、コンパイルされません。何か他のことを手伝ったり提案したりできますか?
フローから読み取ろうとする非コンパイル試行:
bd.buttonNext.setOnClickListener {
lifecycleScope.launch {
val episode: Episode? = viewModel.episodeFlow().first() <=== Compile ERROR
Snackbar.make(bd.root, "episode ${episode?.name}", Snackbar.LENGTH_SHORT).show()
}
}
このフローは ROOM からのものです。
@Query("SELECT * FROM Episode WHERE id = :id")
fun getEpisode(id: Long): Flow<Episode?>
リポジトリ:
fun getEpisode(episodeId: Long): Flow<Episode?> = dao.getEpisode(episodeId)
ビュー モデル - Id は StateFlow から取得されます。
fun episodeFlow(): Flow<Episode?>
= episodeIdStateFlow.flatMapLatest { episodeId ->
repository.getEpisode(episodeId)
}
コンパイル エラー:
Unresolved reference. None of the following candidates is applicable because of receiver type mismatch:
public fun <T> Array<out TypeVariable(T)>.first(): TypeVariable(T) defined in kotlin.collections
public inline fun <T> Array<out TypeVariable(T)>.first(predicate: (TypeVariable(T)) -> Boolean): TypeVariable(T) defined in kotlin.collections
public fun BooleanArray.first(): Boolean defined in kotlin.collections
public inline fun BooleanArray.first(predicate: (Boolean) -> Boolean): Boolean defined in kotlin.collections
public fun ByteArray.first(): Byte defined in kotlin.collections
public inline fun ByteArray.first(predicate: (Byte) -> Boolean): Byte defined in kotlin.collections
public fun CharArray.first(): Char defined in kotlin.collections
public inline fun CharArray.first(predicate: (Char) -> Boolean): Char defined in kotlin.collections
public fun CharSequence.first(): Char defined in kotlin.text
「回避策」として、エピソードを次のようなインスタンス変数に保存しましたが、可能であればそれを避けたいと思います:
var episode: Episode? = null
...
viewModel.episodeFlow().asLiveData().observe(this) { episode ->
this.episode = episode
}
...
bd.buttonNext.setOnClickListener {
Snackbar.make(bd.root, "episode ${episode?.name}", Snackbar.LENGTH_SHORT).show()
}
=================== 更新/解決策 21/01/15 ==================
stateIn を使用した beigirad (以下の彼の投稿を参照) に触発されたソリューション:
private val _episodeSF = episodeFlow().stateIn(viewModelScope, SharingStarted.Eagerly, null)
val episodeSF: StateFlow<Episode?>
get() = _episodeSF
fun episodeFlow(): Flow<Episode?> = episodeIdSF.flatMapLatest { episodeId ->
repository.episodeFlow(episodeId)
}