Added code example for https://jstobigdata.com/spring/a-functional-endpoint-in-spring-webflux/

Author: Bikraji

webflux-01-functional-approach/README.md

@@ -0,0 +1,14 @@
+1. To run the application
+```shell script
+mvn spring-boot:run
+```
+
+2. Visit the below urls in a browser:
+```
+http://localhost:8080/functional/mono
+```
+
+```
+http://localhost:8080/functional/flux
+```
+3. If needed, change the app-server #port in `src/main/resources/application.yml`

webflux-01-functional-approach/src/main/java/c/jbd/webflux/HelloHandler.java

@@ -11,6 +11,12 @@
 
 @Component
 public class HelloHandler {
+  /**
+   * Serves a plain_text
+   *
+   * @param request
+   * @return
+   */
   public Mono<ServerResponse> monoMessage(ServerRequest request) {
     return ServerResponse.ok()
       .contentType(MediaType.TEXT_PLAIN)
@@ -19,6 +25,12 @@ public Mono<ServerResponse> monoMessage(ServerRequest request) {
       );
   }
 
+  /**
+   * Serves a JSON stream
+   *
+   * @param request
+   * @return
+   */
   public Mono<ServerResponse> fluxMessage(ServerRequest request) {
     return ServerResponse.ok()
       .contentType(MediaType.APPLICATION_STREAM_JSON)

webflux-01-functional-approach/src/main/resources/application.yml

@@ -0,0 +1,2 @@
+server:
+  port: 8080

webflux-01-functional-approach/src/test/java/c/jbd/webflux/FunctionalAppTest.java

@@ -17,9 +17,8 @@ public class FunctionalAppTest {
 
   private final String TEST_MESSAGE = "Welcome to JstoBigdata.com";
 
-
   @Test
-  public void testMonoEndpoint(){
+  public void testMonoEndpoint() {
     Flux<String> msg$ = webTestClient.get()
       .uri("/functional/mono")
       .accept(MediaType.TEXT_PLAIN)
@@ -34,7 +33,7 @@ public void testMonoEndpoint(){
   }
 
   @Test
-  public void testFluxEndpoint(){
+  public void testFluxEndpoint() {
     Flux<String> msg$ = webTestClient.get()
       .uri("/functional/flux")
       .accept(MediaType.APPLICATION_STREAM_JSON)