Unlike the flatMap() method, the map() method of the Mono/Flux object in the Project Reactor will process the item being emitted, synchronously: In the image above, green, yellow, and blue items emitted by Publisher will be processed by the map() method synchronously. The return result… Read More
Project Reactor with Mono and Flux objects may make it difficult for you to think about how to write Unit Test for reactive code. Actually, this will be solved easily if you use the StepVerifier class of the reactor-test library. How is it in details?… Read More
Usually, we write Reactive applications that will run on the main thread but there are cases where we need to use multithread. For example, after receiving an item from the Publisher, the Consumer needs to process something different from that data item. With that manipulation,… Read More
Compare to the flatMap() method in the Java Stream object or the flatMap() method in the Optional object in Java, we can manipulate the Stream or Optional objects of the simpler objects, the flatMap() method of the Mono object or the Flux object in the… Read More
In the previous tutorial, I introduced to you all about Reactive Streams in Java which implements Reactive Streams specification. In this tutorial, I will introduce you all one more library that also implements the Reactive Streams specification: it is Project Reactor. How is it in… Read More
