alex.hart
Observable.create { emitter -> myOldApi.addCallback { obj -> emitter.onNext(obj) } // where to call removeCallback... }