Creating Mono<T> and Flux<T> publishers

Reactor Core 3.x has two specific implementations of Publisher<T> namely Mono<T> and Flux<T>. If Subscriber<T> expects at most one Stream element, Mono<T> must be generated. And if at least one is needed to be transmitted, it must be the Flux<T> type. This recipe will expound on how to use these Stream types.

Getting started

This recipe will be about how to use Mono<T> and Flux<T> Stream types given raw data from unit tests and forms. Although they were used in the previous recipe in generating Publisher<T> Streams, nothing has been mentioned about their basic usage. The same Maven project, ch07 will be used for this particular recipe.

How to do it...

After the generic API classes, let us deal with the specific APIs of Spring Reactor 3.0 by using the following steps:

1. Create a service interface EmployeeNativeStreamservice that contains some non-DAO related services which will exhibit how to...