Observable contract describes what assumptions are safe to make about interactions between an Observable and an Observer. Originally presented by Microsoft as a set of Rx design principles, it’s been formalised and captured in Rx documentation. This post highlights essential parts of the contracts and provides code examples for better Read more…
One of my previous posts about back pressure mentions a concept of an Observable without providing many details. This post is a deeper dive into how the Observer pattern is applied in the world of reactive programming. Observer Pattern: Pros and Cons First off, let’s have a look at the Observer Read more…
Counting words in large files is a “hello world” in the big data space. I wanted to share thoughts on sustainable processing of large files using Reactive Streams approach, namely with RxJava. This post outlines how to read and process contents of a large text file without overwhelming the system Read more…
In this post I look into practical applications of a back pressure when building data intensive pipelines with RxJava. I explain what a hot source is and how to handle large data streams without overwhelming the system. As usual there are trade-offs to consider. Please read on if that sounds Read more…
As a follow-up on my previous post about changes to Oracle Java, I am providing a quick comparison of OpenJDK providers. The goal is to give you a rough idea of what to expect in terms of alternatives to Oracle JDK: LTS, pricing, features etc. The list is likely incomplete Read more…
A lot has recently changed in the Java landscape. While Java 9 warrants design considerations many legacy apps will stumble upon, its adoption is an essential step to make. Mind you, both Java 9 and 10 are only short-term releases. Java 11 starts a new era of a much shorter Read more…