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?