Observable.fromCallable () implementación con exception

Estoy tratando de ejecutar una function que arroja excepciones.

Observable.fromCallable { foo() } .subscribeOn(Schedulers.io()) .observeOn(AndroidSchedulers.mainThread()) .take(1) .onErrorReturn { /* onError operation */ } .subscribe { } 

y quiero hacer alguna otra operación si tiene éxito sin ningún error. ¿Cómo puedo hacer eso?

Quiero hacer alguna otra operación si tiene éxito sin ningún error

Todos esos operadores se aplicarán a su transmisión a less que haya ocurrido una exception, lo que significa que no tiene que preocuparse por el caso "si tiene éxito" , solo debería ocuparse del caso "si no tiene éxito" .

Si, por algún motivo, se ha producido un error, solo se onErrorReturn() .

  • Encadenando Observables para evitar suscripciones múltiples
  • Retrofit-Vertx con RxJava2 en Kotlin IllegalStateException message == null
  • ¿Cómo soluciono el error de inferencia de tipo en un Completable transformado utilizando RxLifecycle.bindToLifecycle ()?
  • ¿Cómo se simula emitir 2 streams infinitas observables y tener otras observables que las fusionan y amortiguan cada 10 segundos?
  • Cómo crear el controller de respuesta genérica para el error y validar la respuesta utilizando retrofit, rxjava y dagger
  • RxJava2 switchIfEmpty y verificando una ejecución
  • Escuchar posts y escribir commands en un flujo observable
  • ¿Por qué no puedo usar la interfaz como el tipo genérico en este transformador Rx?
  • Extraño comportamiento de componer y ObservableTransformer en RxJava cuando el genérico pasado se extiende
  • Completable.andThen resultados en "other is null"
  • ¿Por qué tengo un Log de salida no deseado al fusionar 2 observables en otro Observable, que los almacena temporalmente cada 10 segundos?