TopicProcessor in Project Reactor: Spreading the message to many
When building your Reactive Application, you sometimes want to split up your single stream into several ones, running concurrently. One of the ways this can be done using the TopicProcessor. Very similary to the concept of a Topic seen in JMS, a TopicProcessor can be used to subscribe on one or multiple streams, and have … Continue reading "TopicProcessor in Project Reactor: Spreading the message to many"
Read MoreCombining Fluxes in Project Reactor
Analogous to combining Mono’s, which we discussed in this article we can also combine Fluxes in several ways. With Project Reactor we can use Fluxes to signal back zero, one, or more than one element. This makes it inherently different to the Mono datatype, which is only able to return one or zero elements. This … Continue reading "Combining Fluxes in Project Reactor"
Read MoreCombining Monos in Project Reactor
The Mono datatype in Project Reactor is used to make a Reactive operator that will signal back either a single element or an error somewhere in the future. We can even launch several of them, not blocking any threads while waiting for results to arrive. There are several ways to combine these Monos. We’ll look … Continue reading "Combining Monos in Project Reactor"
Read MoreEasily Faking I/O load for Reactive experiments
When investigating the benefits of Reactive Programming it is very useful to be able to simulate a heavy I/O load. This will help by enabling you to prove to yourself, and to others one of the major advantages of Reactive Programming, the fact that slow I/O does not block the CPU. This way your CPU … Continue reading "Easily Faking I/O load for Reactive experiments"
Read MoreReactive programming, the basics
Reactive programming is a programming paradigm which is supported in frameworks like Spring 5 (Project Reactor) and Java 9 (Reactive Streams). Earlier there was already support with RxJava, Project Reactor and the Reactive Streams standard. As such the concepts behind Reactive programming are not new but using them becomes easier and more supported. Reactive programming will help us deal with threads more efficiently. Rather than working with one thread per request, all tasks will be shared over multiple threads. All tasks will be handled without blocking a thread while waiting for a response. [async] [non-blocking] (Parts of) Information is provided as soon … Continue reading "Reactive programming, the basics"
Read More