This directory contains all the Project Reactor source code examples. Here's an overview of what's included:
. ex1 - This example demonstrates various reactive algorithms for finding all the minimum values in an unordered list, which is surprisingly not well documented in the literature. These three algorithms use Project Reactor features to return Flux/Mono reactive types that emit the cheapest flight(s) from a Flux of available flights. Another three algorithms use Java Streams features to perform the same computations.
. ex2 - This program applies Project Reactor features to check the primality of randomly generate Integer objects via a publisher and a subscriber that (conditionally) run in different threads/schedulers.
. ex3 - This program applies Project Reactor features to implement various types of backpressure strategies (e.g., ignore, buffer, error, latest, drop, and push/pull) between a publisher and a subscriber that (conditionally) run in different threads/schedulers.
. ex4 - This program applies Project Reactor features to measure the performance of checking random numbers for primality with and without various types of memoizers (e.g., untimed and timed) based on Java ConcurrentHashMap.
. ex5 - This example shows how to apply timeouts with the Project Reactor framework.
. ex6 - This program shows performance differences between Project Reactor's single-threaded Flux, the flatMap() concurrency idiom, and several variants of ParallelFlux when creating Set objects containing the unique words appearing in the complete work of William Shapespeare.