Tomasz Nurkiewicz
Java Code Geeks
Poland
Contact Tomasz
Discover and connect with journalists and influencers around the world, save time on email research, monitor the news, and more.
| Recent: |
|
| Past: |
|
Past articles by Tomasz:
Monitoring and measuring reactive application with Dropwizard Metrics
In the previous article we created a simple indexing code that hammers ElasticSearch with thousands ... → Read More
Idiomatic concurrency: flatMap() vs. parallel() – RxJava FAQ
Simple, effective and safe concurrency was one of the design principles of RxJava. Yet, ironically, ... → Read More
Detecting and testing stalled streams – RxJava FAQ
Imagine you have a stream that publishes events with unpredictable frequency. Sometimes you can expe... → Read More
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 tas... → Read More
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 RxJa... → Read More
Loading files with backpressure – RxJava FAQ
Processing file as a stream turns out to be tremendously effective and convenient. Many people seem ... → Read More
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... → Read More
1.x to 2.x migration: Observable vs. Observable: RxJava FAQ
The title is not a mistake. rx.Observable from RxJava 1.x is a completely different beast than io.re... → Read More
flatMap() vs. concatMap() vs. concatMapEager() – RxJava FAQ
There are three, seamlessly similar operators in RxJava 2.x: flatMap(), concatMap() and concatMapEag... → Read More
Eager subscription – RxJava FAQ
While teaching and mentoring RxJava, as well as after authoring a book, I noticed some areas are esp... → Read More
Beware of slow transaction callbacks in Spring
TL;DR If your application is failing to obtain new database connection, restarting ActiveMQ broker ... → 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 i... → Read More
Small scale stream processing kata. Part 1: thread pools
Once again I prepared a programming contest on GeeCON 2016 for my company. This time the assignment ... → Read More
Guide to time and date in Java
Properly handling dates, time, time zones, daylight saving time, leap years and such has been my pet... → Read More
Functor and monad examples in plain Java
This article was initially an appendix in our Reactive Programming with RxJava book. However introdu... → Read More
Optional in Java 8 cheat sheet
java.util.Optional in Java 8 is a poor cousin of scala.Option[T] and Data.Maybe in ... → Read More
Asynchronous retry pattern
When you have a piece of code that often fails and must be retried, this Java 7/8 library provides r... → Read More
Macro lifecycle in Clojure
If you still struggle to understand what are macros in Clojure and why are they so useful, I will gu... → Read More
Which thread executes CompletableFuture’s tasks and callbacks?
CompletableFuture is still a relatively fresh concept, despite being introduced almost two years ago... → 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 tha... → Read More