This repository breaks down learning of reactive types such as Mono and Flux. This repository contains examples using these reactive types in Spring5 Web Flux Framework
Reactor = single threaded event loop that receives and processes requests.
The reactor design pattern is an event handling pattern for handling service requests delivered concurrently to a service handler by one or more inputs. The service handler then demultiplexes the incoming requests and dispatches them synchronously to the associated request handlers.
Endpoint | Description | Result |
---|---|---|
/flux/strings | returns flux of strings created using Flux.just() | "BARATH" |
/flux/fromArray | returns flux of strings created using Flux.just() | "BARATH" |
/flux/concat | returns flux of strings created using Flux.just() | "BARATH" |
/flux/merge | returns flux of strings created using Flux.just() | "BARATH" |
/mono/string | returns flux of strings created using Flux.just() | "BARATH" |
/mono/string/delay | returns flux of strings created using Flux.just() | "BARATH" |
/mono/doOnNext | returns flux of strings created using Flux.just() | "BARATH" |
/mono/int | returns flux of strings created using Flux.just() | "BARATH" |
/flux/user/one | returns flux of strings created using Flux.just() | "BARATH" |
/flux/fromIterable | returns flux of strings created using Flux.just() | "BARATH" |
- Clone the repository
- Maven build
./mvnw clean install
- Run as spring boot app:
./mvnw spring-boot:run
References:
http://musigma.org/java/2016/11/21/reactor.html http://javasampleapproach.com/reactive-programming/reactor/reactor-how-to-combine-flux-mono-reactive-programming