SharedFlow.last() 永远不会返回

Question

我有一个重播值为 1 的共享流。但是当我尝试访问最后发出的值时，调用永远不会返回（而确实first()如此）。

下面是我的代码：

val game = GameSettingsRepository.gameIdFlow.flatMapLatest { gameId ->
    gameId?.let { gameDataSource.getGame(it) }
        ?: flowOf()
}.shareIn(ProcessLifecycleOwner.get().lifecycleScope, SharingStarted.Eagerly, 1)

其中getGame()是回调流程：

override fun getGame(gameId: String): Flow<Game> = callbackFlow {
    val listener = object : ValueEventListener {
        override fun onDataChange(snapshot: DataSnapshot) {
            snapshot.getValue(GameFirebase::class.java)?.let { gameFirebase ->
                    trySend(gameFirebase.toData())
                }
            }
        }

        override fun onCancelled(error: DatabaseError) {
            TODO("Not yet implemented")
        }

    }
    db.child(gameId).addValueEventListener(listener)
    awaitClose { db.child(gameId).removeEventListener(listener) }
}

所以这个：val myGame = game.last()永远不会返回任何东西，而会返回任何东西val myGame = game.first()。

为什么以及如何？

Answer 1

SharedFlow 是无限的。它永远开放，等待未来可能的排放。因此，它没有最后一个元素。

该last()函数的工作原理是收集整个 Flow，然后返回最后的结果。由于collect()在 SharedFlow 上调用时永远不会返回，last()因此也永远不会返回。它将永远暂停。