https://kotlinlang.org logo
#rx
Title
z

zak.taccardi

05/24/2018, 9:56 PM
Copy code
Observable.create { emitter ->
    
    val listener = // . . emitter.onNext(data)
     db.addListener(listener)
    emitter.setDisposable { db.removeListener(listener) }
}