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

Question

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

Answer 1

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

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