flatMap() and the order of events – RxJava FAQ

As we already discovered, flatMap() does not preserve the order of original stream. Let’s illustrate this using the GeoNames API example from previous article: public…

Read More »

flatMap() vs. concatMap() vs. concatMapEager() – RxJava FAQ

There are three, seamlessly similar operators in RxJava 2.x: flatMap(), concatMap() and concatMapEager(). All of them accept the same argument – a function from…

Read More »

Eager subscription – RxJava FAQ

While teaching and mentoring RxJava, as well as after authoring a book, I noticed some areas are especially problematic. I decided…

Read More »

Small scale stream processing kata. Part 2: RxJava 1.x/2.x

In part 1: thread pools we designed and implemented relatively simple system for processing events in real time. Make sure…

Read More »

Parallel execution of blocking tasks with RxJava and Completable

” How parallel execution of blocking “side-effect only” (aka void) tasks became easier with Completable abstraction introduced in RxJava 1.1.1.…

Read More »

Server-sent events with RxJava and SseEmitter

Spring framework 4.2 GA is almost released, let’s look at some new features it provides. The one that got my…

Read More »

Use reactive streams API to combine akka-streams with rxJava

Just a quick article this time, since I’m still experimenting with this stuff. There is a lot of talk around…

Read More »

RxJava + Java8 + Java EE 7 + Arquillian = Bliss

Microservices are an architectural style where each service is implemented as an independent system. They can use their own persistence…

Read More »

Turning Twitter4J into RxJava’s Observable

aTwitter4J is a Java wrapper around Twitter API. While Twitter supports simple request-response interactions in this article we will explore…

Read More »