我正在使用Spring5和couchbase进行反应式编程。有人能详细解释一下反应式java是如何从couchbase拉入数据的吗?couchbase如何提供响应式支持?提前谢谢。
发布于 2019-02-09 19:45:30
Couchbase Java客户端是使用RxJava 1实现的,至少在2.x版本之前是这样。
例如,如果您查看文档异步操作,则可以通过插入对get
的调用将该操作转换为可观察的流。也就是说,bucket.async().get(id)
返回一种类型的Observable<JsonDocument>
。
https://stackoverflow.com/questions/54252732
复制相似问题