tests.kt

// Вот так пашет
private lateinit var cards: RealmResults<RealmCardEntity>
    override fun subscribeForChanges(onChange: (card: CardEntity) -> Unit) {
        val realm = Realm.getDefaultInstance()
        cards = realm.where(RealmCardEntity::class.java)
            .findAllAsync()

        cards.addChangeListener { results ->
            results.let { realm.copyFromRealm(it) }
                .map { it.toDomain() }
                .forEach(onChange)
        }
    }
	
// Не пашет
private var changes: RealmResults<RealmCardEntity>? = null
    override fun subscribeForChanges(): Observable<CardEntity> = Observable.create { emitter ->
        Realm.getDefaultInstance().executeTransaction { realm ->
            changes = realm.where(RealmCardEntity::class.java)
                .findAll()

            changes?.addChangeListener { result, changeSet ->
                result.forEach { emitter.onNext(it.toDomain()) }
            }
        }

    }	
	
	
	
// Не пашет
private lateinit var changes: RealmResults<RealmCardEntity>
    override fun subscribeForChanges(): Observable<CardEntity> = Observable.create { emitter ->
        Realm.getDefaultInstance().executeTransactionAsync { realm ->
            changes = realm.where(RealmCardEntity::class.java)
                .findAllAsync()


            changes.addChangeListener { result, changeSet ->
                result.forEach { emitter.onNext(it.toDomain()) }
            }
        }

    }