java - 在 Couchbase Java SDK 中使用 toBlocking() 的正确方法是什么？

Question

这里是Couchbase新手，使用Couchbase Server v4.0.0和Java SDK v2.2.3。我有以下用于运行查询的代码

Observable
            .defer(new Func0<Observable<AsyncN1qlQueryResult>>() {
                @Override
                public Observable<AsyncN1qlQueryResult> call() {
                    return bucket.async().query(query);
                }
            })
            .flatMap(new Func1<AsyncN1qlQueryResult, Observable<AsyncN1qlQueryRow>>() {
                @Override
                public Observable<AsyncN1qlQueryRow> call(AsyncN1qlQueryResult result) {
                    return result.rows();
                }
            })
            .map(new Func1<AsyncN1qlQueryRow, JsonObject>() {
                @Override
                public JsonObject call(AsyncN1qlQueryRow row) {
                    return row.value();
                }
            })
            .toList()
            .toBlocking()
            .firstOrDefault(null);

查询预计会返回两个结果，我可以保证它没有任何问题。但是，如果我让它运行，则该表达式的计算结果为 null。我怀疑我切换到阻塞可观察量的方式可能有问题，或者可能是延迟。

一个有趣的观察是，如果我在 Debug模式下运行它并在 return bucket.async().query(query); 行设置断点，并在每次使用调试器时跳过它，我总是会得到一个包含 2 个元素的列表。 (这只是查询不是罪魁祸首的另一个证据。)

有人能发现我的习语有什么问题吗？

Answer 1

虽然我不知道您的 N1QL，但请检查以下内容:

1. 您不应该以 Observable.defer() 开头；只需从 asyncBucket.query() 开始，因为 asyncBucket.query(q) 或 syncBucket.async().query(q) 已经以延迟方式实现。
2. singleOrDefault() 与 toList() 一起使用时相关。 (但是，在这种情况下可能并不重要。)