RxJava
-
Enterprise Java
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 » -
Enterprise Java
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 » -
Core Java
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 » -
Core Java
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 » -
Enterprise Java
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 » -
Core Java
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 » -
Enterprise Java
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 » -
Enterprise Java
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 » -
Core Java
RxJava: From Future to Observable
I first came across Reactive Extensions about 4 years ago on Matthew Podwysocki’s blog but then haven’t heard much about…
Read More »
