Как реактивный Java-доступ к данным из couchbase?

Java-клиент Couchbase реализован с RxJava 1, по крайней мере, в версиях 2.x.

Если вы посмотрите, например, на операцию документа get, вы можете превратить эту операцию в наблюдаемый поток, вставив вызов async. Таким образом, bucket.async().get(id) возвращает тип Observable<JsonDocument>.