Tag: rxjava
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...
Use Couchbase and RxJava to Make Java Read CSV files
RxJava is an awesome tool for reactive programming that’s also useful as a Java CSV reader. In case you’ve never used or even heard of RxJava, it is a a way of programming with asynchronous data streams. It is also...
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...