Tag: rxjava

ReactiveX Logo

Exploring RxJava – Wrapping a Listener Callback

In this post, I’ll show how to convert a callback-based listener style API to a reactive one with RxJava 2. Contents Introduction Objective Getting Started Creating a Source Listing: BasicSource.java Listing: UnboundSource.java Converting to an Observable Listing: Observables.java Instantiation and...

The Simplicity of RxJava with N1QL Queries and Couchbase

The Simplicity of RxJava with N1QL Queries and Couchbase Have you ever tried to query Couchbase using N1QL and the Java SDK's synchronous API? It works well and isn't particularly difficult, but I find it to be a little messy,...

A CRUD REST API with Couchbase, RxJava and Ratpack

In my two previous blog posts I have introduced Ratpack and the lightweight ODM layer available in our Java SDK. This post will build up on them and showcase a REST API to manage users through the Couchbase repository. I...

Ratpack, Couchbase and RxJava

Yesterday I left you with rough code that started a Ratpack server and used a synchronous Couchbase repository, leaving the RxJava part out. I intend to fix that today, and also tell you more about Ratpack. I am not going...

Load CSV Data into Couchbase using RxJava

RxJava is an awesome way to do reactive programming in Java. In case you've never used or even heard of RxJava, it is a a way of programming with asynchronous data streams. That said, it is event based programming where...

Move Documents from MongoDB to Couchbase

Maybe you remember my post about moving data from CouchDB to Couchbase. If you are not using CouchDB but MongoDB you might have felt let down. I am sorry. Let’s fix this. Here’s how to move your data out of...