Integration Realm DataBase и kotlinx.coroutines

getData.kt

fun getData() = produce<List<Data>>(LooperThread) {
    var results = realm.where(Data::class.java).findAll()
    send(map(results))
    results.addChangeListener { results ->
        run {
            launch(LooperThread) {
                send(map(results))
            }
        }
    }
}

//Rx version used Observable default library implementation like

override fun <E : RealmModel> from(realm: Realm, results: RealmResults<E>): Observable<RealmResults<E>> {
        val realmConfig = realm.configuration

        return Observable.create { subscriber ->
            val observableRealm = Realm.getInstance(realmConfig)
            resultsRefs.get().acquireReference(results)

            val listener = RealmChangeListener<RealmResults<E>> {
                if (!subscriber.isUnsubscribed) {
                    subscriber.onNext(results)
                }
            }
            results.addChangeListener(listener)
            subscriber.add(Subscriptions.create {
                results.removeChangeListener(listener)
                observableRealm.close()
                resultsRefs.get().releaseReference(results)
            })
            subscriber.onNext(results)
        }
}