执行操作符而不是整个订阅者

使用起来相当有吸引力Action(s) 而不是整个Subscriber当你只需要OnNext()只是因为它更具可读性。但当然，错误会发生，如果你只使用Action1你会得到一个Exception在你的应用程序中。do 运营商 http://reactivex.io/documentation/operators/do.html可以在这里提供帮助。我只是担心这两种方法完全相同，请确认或不确认。有什么陷阱吗？

第一种方法：

Observable
        .just(readFromDatabase())
        .doOnError(new Action1<Throwable>() {
          @Override public void call(Throwable throwable) {
            // handle error
          }
        }).subscribe(new Action1<SomeData>() {
          @Override public void call(SomeData someData) {
            // react!
          }
    });

第二种方法：

Observable
        .just(readFromDatabase())
        .subscribe(new Subscriber<SomeData>() {
          @Override public void onCompleted() {
            // do nothing
          }

          @Override public void onError(Throwable e) {
            // handle error
          }

          @Override public void onNext(SomeData someData) {
            // react!
          }
        });

谢谢你！

两种方法并不完全相同，您将从第一种方法中得到一些惊喜：

第一个惊喜是doOnError不消耗错误，而仅对其执行一些操作。因此，在您的情况下，如果流生成错误，它将通过您的doOnError代码，然后立即触发OnErrorNotImplementedException，就像doOnError步骤不存在。

假设您意识到这一点，并向您的订阅调用添加一个空的错误处理程序：

Observable
    .just(readFromDatabase())
    .doOnError(...)
    .subscribe(..., error -> { /* already handled */ } );

然后你就可以遇到下一个细微的差别了。do*块被视为流的一部分，这意味着块中任何未捕获的异常都将导致流错误（与“onNext/OnError/onComplete”块中抛出的异常相反，这些异常要么被忽略，要么立即抛出，从而取消订阅在途中）。

因此，在上面的示例中，如果我们说您的数据库读取触发了流错误A，它被传递给doOnError块，抛出异常B，那么我们添加的（空）订阅错误处理程序将收到B（并且仅B).

后面的区别并不是很重要doOnError（因为无论如何流都会终止），但是当发生在doOnNext，其中异常的行为与 subscribe 中抛出的相同异常有非常不同的行为onNext块（出错的流与隐式取消的流）。