使用rx-java2进行验证：出现第一个错误

Question

我正在尝试使用rx-java并行验证一个大文件，并在发生任何验证错误时立即返回。我的代码如下所示：Observable<ValidationError> observable = Observable.fromIterable(lines).flatMap(line -> Observable            .just(line)            .subscribeOn(Schedulers.computation())            .map(lineParser::parse)            .map(lineValidator::validator)    //validation returns Optional<ValidationError>            .filter(Optional::isPresent)            .map(Optional::get));这会导致文件中出现任何错误的Observable，但我不知道该如何实现，以便在第一次出现时就停止计算。我已经看到有一个blockingFirst方法，该方法似乎将返回第一个错误，但是应该在文件中未发现任何错误时引发Exception，这会使我的代码难看。有什么帮助吗？