-
Enterprise Java
Monitoring and measuring reactive application with Dropwizard Metrics
In the previous article we created a simple indexing code that hammers ElasticSearch with thousands of concurrent requests. The only way to…
Read More » -
Enterprise Java
Spring, Reactor and ElasticSearch: bechmarking with fake test data
In the previous article we created a simple adapter from ElasticSearch’s API to Reactor’s Mono, that looks like this: import reactor.core.publisher.Mono; private Mono…
Read More » -
Enterprise Java
Spring, Reactor and ElasticSearch: from callbacks to reactive streams
Spring 5 (and Boot 2, when it arrives in a couple of weeks) is a revolution. Not the “annotations over XML”…
Read More » -
Core Java
Idiomatic concurrency: flatMap() vs. parallel() – RxJava FAQ
Simple, effective and safe concurrency was one of the design principles of RxJava. Yet, ironically, it’s probably one of the…
Read More » -
Core Java
Detecting and testing stalled streams – RxJava FAQ
Imagine you have a stream that publishes events with unpredictable frequency. Sometimes you can expect dozens of messages per second,…
Read More » -
Core Java
Fixed-rate vs. fixed-delay – RxJava FAQ
If you are using plain Java, since version 5 we have a handy scheduler class that allows running tasks at…
Read More » -
Core Java
Streaming large JSON file with Jackson – RxJava FAQ
In the previous article, we learned how to parse excessively large XML files and turn them into RxJava streams. This time let’s…
Read More » -
Core Java
Loading files with backpressure – RxJava FAQ
Processing file as a stream turns out to be tremendously effective and convenient. Many people seem to forget that since…
Read More » -
Core Java
Generating backpressure-aware streams with Flowable.generate() – RxJava FAQ
RxJava is missing a factory to create an infinite stream of natural numbers. Such a stream is useful e.g. when…
Read More »
