我用弹簧5与couchbase反应式编程工作。详细谁能解释如何反应的Java数据拉从couchbase?如何couchbase提供无功支持?提前致谢。
该Couchbase Java客户端通过在2.x版本的RxJava 1日实施,至少。
如果你看一下,例如,文档get操作,您可以通过插入到异步调用打开操作成可观察到的数据流。也就是说,bucket.async().get(id)返回类型Observable<JsonDocument>的。
get
bucket.async().get(id)
Observable<JsonDocument>