reactive java 如何从 couchbase 访问数据?

How does reactive java access data from couchbase?

我正在使用 spring 5 和 couchbase 的反应式编程。谁能详细解释 reactive java 如何从 couchbase 中提取数据? Couchbase 如何提供响应式支持?提前致谢。

Couchbase Java 客户端是使用 RxJava 1 实现的,至少在 2.x 版本中是这样。

例如,如果您查看文档 get 操作,您可以通过插入对异步的调用将操作转变为可观察的流。即bucket.async().get(id)returns一种Observable<JsonDocument>.