android - RxJava : catch exception properly

Question

我试图在 Schedulers IO 线程中执行一些 IO 操作，如果抛出异常，我想向用户显示一些 Toast。

为此，我使用以下代码:

Observable.interval(0, 15, TimeUnit.SECONDS)
            .observeOn(Schedulers.io())
            .doOnNext(event -> new Repository().inputOutput(MainActivity.this);)
            .observeOn(AndroidSchedulers.mainThread())
            .doOnError(throwable -> 
                    Toast.makeText(MainActivity.this, "Error message", Toast.LENGTH_SHORT).show())
            .subscribe();

当方法“inputOutput”抛出异常时，我希望 Throwable 被“doOnError”消费者捕获，但它并没有发生，异常被抛给周围的代码。

我做错了什么？非常感谢!

Answer 1

应该是这样的:

Observable.interval(0, 15, TimeUnit.SECONDS)
              .flatMap(event -> new Repository().inputOutput(MainActivity.this);)        
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe({your onNext/onComplete handler}, throwable -> 
                    Toast.makeText(MainActivity.this, "Error message", Toast.LENGTH_SHORT).show()));