如何使用rxAndroid递归调用api，直到满足某些条件？

Observable.create(new Observable.OnSubscribe<Result>() {
    @Override
    public void call(Subscriber<? super Result> subscriber) {
        // 调用API，并将结果发射给订阅者
        Result result = callApi();
        subscriber.onNext(result);
        subscriber.onCompleted();
    }
})
.flatMap(new Func1<Result, Observable<Result>>() {
    @Override
    public Observable<Result> call(Result result) {
        // 判断是否满足递归调用的条件
        if (isConditionMet(result)) {
            // 继续递归调用API
            return Observable.just(callApi());
        } else {
            // 不再满足条件，结束Observable的发射
            return Observable.empty();
        }
    }
})
.filter(new Func1<Result, Boolean>() {
    @Override
    public Boolean call(Result result) {
        // 过滤满足某些条件的结果
        return isResultValid(result);
    }
})
.subscribe(new Subscriber<Result>() {
    @Override
    public void onNext(Result result) {
        // 处理满足条件的结果
    }

    @Override
    public void onCompleted() {
        // Observable发射完成
    }

    @Override
    public void onError(Throwable e) {
        // 处理错误情况
    }
});