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