Search code examples
spring-bootreactive-programmingcouchbasespring-data-couchbase

How does reactive java access data from couchbase?


I'm working with spring 5 and reactive programming with couchbase. Can anyone explain in detail how does reactive java pull in data from couchbase? How does couchbase provide reactive support? Thanks in advance.


Solution

  • The Couchbase Java client is implemented with RxJava 1, at least through the 2.x versions.

    If you look at, for example, a document get operation, you can turn the operation into an observable stream by inserting a call to async. That is, bucket.async().get(id) returns a type of Observable<JsonDocument>.