继续执行链接的RxJava observable on error，仅在满足特定条件时停止执行

Observable.just(1, 2, 3, 4, 5)
    .flatMap(num -> {
        if (num == 3) {
            return Observable.error(new Exception("Error occurred"));
        } else {
            return Observable.just(num);
        }
    })
    .onErrorResumeNext(throwable -> {
        // 处理错误并返回一个新的Observable
        return Observable.just(6, 7, 8);
    })
    .takeWhile(num -> num <= 6)
    .subscribe(
        num -> System.out.println("onNext: " + num),
        throwable -> System.out.println("onError: " + throwable.getMessage()),
        () -> System.out.println("onComplete")
    );

onNext: 1
onNext: 2
onError: Error occurred