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>
.
我正在使用 spring 5 和 couchbase 的反应式编程。谁能详细解释 reactive java 如何从 couchbase 中提取数据? Couchbase 如何提供响应式支持?提前致谢。
Couchbase Java 客户端是使用 RxJava 1 实现的,至少在 2.x 版本中是这样。
例如,如果您查看文档 get
操作,您可以通过插入对异步的调用将操作转变为可观察的流。即bucket.async().get(id)
returns一种Observable<JsonDocument>
.