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

Question

Я работаю с пружиной 5 и реактивного программирования с couchbase. Кто-нибудь может объяснить подробно, как реактивная Java получает данные из couchbase? Как couchbase обеспечивает реактивную поддержку? Заранее спасибо.

Answer 1

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

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