toFlow

返回监控此 RealmObject 更改的流。 它将在订阅时发出当前 RealmObject。 更新 RealmObject 时将不断发出对象更新 — 永远不会调用onCompletion 。

从Realm流发出的项目被冻结 - 请参阅RealmObject.freeze 。 这意味着它们是不可变的，可以从任何线程读取。

Realm 流始终从持有活动 RealmObject 的线程中发出项目。 这意味着，如果需要进行进一步处理，建议在计算调度程序上收集值：

object.toFlow()
  .map { obj -> doExpensiveWork(obj) }
  .flowOn(Dispatchers.IO)
  .onEach { flowObject ->
    // ...
  }.launchIn(Dispatchers.Main)

如果您希望toFlow()停止发出项目，您可以通过调用kotlinx.coroutines.flow.first来指示流程仅发出第一项：

val foo = object.toFlow()
  .flowOn(context)
  .first()

返回
可以调用onEach或collect的Kotlin Flow 。