fun <T : RealmModel> T?.toFlow(): Flow<T?>
Retorna um fluxo que monitora alterações neste RealmObject. Ele emitirá o RealmObject atual após a assinatura. As atualizações de objetos serão emitidas continuamente à medida que o RealmObject é atualizado - onCompletion nunca será chamado.
Os itens emitidos dos fluxos de Realm são congelados — consulte RealmObject.freeze. Isso significa que eles são imutáveis e podem ser lidos em qualquer thread.
Os fluxos de Realm sempre emitem itens do thread que contém o RealmObject ativo. Isso significa que, se você precisar fazer processamento adicional, é recomendável coletar os valores em um despachante de computação:
object.toFlow()
.map { obj -> doExpensiveWork(obj) }
.flowOn(Dispatchers.IO)
.onEach { flowObject ->
// ...
}.launchIn(Dispatchers.Main)
Se quiser que toFlow() pare de emitir itens, você pode instruir o fluxo a emitir apenas o primeiro item ligando para kotlinx.coroutines.flow.first:
val foo = object.toFlow()
.flowOn(context)
.first()
Return
Kotlin Flow em quais chamadas para onEach ou collect podem ser feitas.