``` Observable.create { emitter -> val...

# rx

[zak.taccardi]

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