Realm Kotlin 0.40 Release Blog Post - Threadsafe Observers

ThreadsafeObservers.kt

val jane = getJane()
CoroutineScope(Dispatchers.Main).launch {

   // Run mapping/transform logic in the background
   val flow: Flow<String> = jane.observe()
       .filter { it.name.startsWith("Jane") }
       .flowOn(Dispatchers.Unconfined)

   // Before collecting on the UI thread
   flow.collect {
       println(it.name)
   }
}