Observable.create { emitter ->
    
    val listener = // . . emitter.onNext(data)
     db.addListener(listener)
    emitter.setDisposable { db.removeListener(listener) }
}