重复查询db & rxjava observableResult多次调用后续函数

Observable.create(new ObservableOnSubscribe<QueryResult>() {
    @Override
    public void subscribe(ObservableEmitter<QueryResult> emitter) throws Exception {
        // 执行数据库查询操作，并将结果通过emitter发射出去
        QueryResult result = queryDatabase();
        emitter.onNext(result);
        emitter.onComplete();
    }
})
.flatMap(new Function<QueryResult, ObservableSource<Result>>() {
    @Override
    public ObservableSource<Result> apply(QueryResult queryResult) throws Exception {
        // 对查询结果进行处理，并返回Observable对象
        Result processedResult = processQueryResult(queryResult);
        return Observable.just(processedResult);
    }
})
.subscribe(new Consumer<Result>() {
    @Override
    public void accept(Result result) throws Exception {
        // 处理最终结果
        handleResult(result);
    }
});