WebFlux POC initial commit

.gitignore

+HELP.md
+target/
+!.mvn/wrapper/maven-wrapper.jar
+!**/src/main/**/target/
+!**/src/test/**/target/
+
+### STS ###
+.apt_generated
+.classpath
+.factorypath
+.project
+.settings
+.springBeans
+.sts4-cache
+
+### IntelliJ IDEA ###
+.idea
+*.iws
+*.iml
+*.ipr
+
+### NetBeans ###
+/nbproject/private/
+/nbbuild/
+/dist/
+/nbdist/
+/.nb-gradle/
+build/
+!**/src/main/**/build/
+!**/src/test/**/build/
+
+### VS Code ###
+.vscode/

.mvn/wrapper/maven-wrapper.properties

+distributionUrl=https://repo.maven.apache.org/maven2/org/apache/maven/apache-maven/3.8.6/apache-maven-3.8.6-bin.zip
+wrapperUrl=https://repo.maven.apache.org/maven2/org/apache/maven/wrapper/maven-wrapper/3.1.0/maven-wrapper-3.1.0.jar

mvnw

+#!/bin/sh
+# ----------------------------------------------------------------------------
+# Licensed to the Apache Software Foundation (ASF) under one
+# or more contributor license agreements.  See the NOTICE file
+# distributed with this work for additional information
+# regarding copyright ownership.  The ASF licenses this file
+# to you under the Apache License, Version 2.0 (the
+# "License"); you may not use this file except in compliance
+# with the License.  You may obtain a copy of the License at
+#
+#    https://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing,
+# software distributed under the License is distributed on an
+# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+# KIND, either express or implied.  See the License for the
+# specific language governing permissions and limitations
+# under the License.
+# ----------------------------------------------------------------------------
+
+# ----------------------------------------------------------------------------
+# Maven Start Up Batch script
+#
+# Required ENV vars:
+# ------------------
+#   JAVA_HOME - location of a JDK home dir
+#
+# Optional ENV vars
+# -----------------
+#   M2_HOME - location of maven2's installed home dir
+#   MAVEN_OPTS - parameters passed to the Java VM when running Maven
+#     e.g. to debug Maven itself, use
+#       set MAVEN_OPTS=-Xdebug -Xrunjdwp:transport=dt_socket,server=y,suspend=y,address=8000
+#   MAVEN_SKIP_RC - flag to disable loading of mavenrc files
+# ----------------------------------------------------------------------------
+
+if [ -z "$MAVEN_SKIP_RC" ] ; then
+
+  if [ -f /usr/local/etc/mavenrc ] ; then
+    . /usr/local/etc/mavenrc
+  fi
+
+  if [ -f /etc/mavenrc ] ; then
+    . /etc/mavenrc
+  fi
+
+  if [ -f "$HOME/.mavenrc" ] ; then
+    . "$HOME/.mavenrc"
+  fi
+
+fi
+
+# OS specific support.  $var _must_ be set to either true or false.
+cygwin=false;
+darwin=false;
+mingw=false
+case "`uname`" in
+  CYGWIN*) cygwin=true ;;
+  MINGW*) mingw=true;;
+  Darwin*) darwin=true
+    # Use /usr/libexec/java_home if available, otherwise fall back to /Library/Java/Home
+    # See https://developer.apple.com/library/mac/qa/qa1170/_index.html
+    if [ -z "$JAVA_HOME" ]; then
+      if [ -x "/usr/libexec/java_home" ]; then
+        export JAVA_HOME="`/usr/libexec/java_home`"
+      else
+        export JAVA_HOME="/Library/Java/Home"
+      fi
+    fi
+    ;;
+esac
+
+if [ -z "$JAVA_HOME" ] ; then
+  if [ -r /etc/gentoo-release ] ; then
+    JAVA_HOME=`java-config --jre-home`
+  fi
+fi
+
+if [ -z "$M2_HOME" ] ; then
+  ## resolve links - $0 may be a link to maven's home
+  PRG="$0"
+
+  # need this for relative symlinks
+  while [ -h "$PRG" ] ; do
+    ls=`ls -ld "$PRG"`
+    link=`expr "$ls" : '.*-> \(.*\)$'`
+    if expr "$link" : '/.*' > /dev/null; then
+      PRG="$link"
+    else
+      PRG="`dirname "$PRG"`/$link"
+    fi
+  done
+
+  saveddir=`pwd`
+
+  M2_HOME=`dirname "$PRG"`/..
+
+  # make it fully qualified
+  M2_HOME=`cd "$M2_HOME" && pwd`
+
+  cd "$saveddir"
+  # echo Using m2 at $M2_HOME
+fi
+
+# For Cygwin, ensure paths are in UNIX format before anything is touched
+if $cygwin ; then
+  [ -n "$M2_HOME" ] &&
+    M2_HOME=`cygpath --unix "$M2_HOME"`
+  [ -n "$JAVA_HOME" ] &&
+    JAVA_HOME=`cygpath --unix "$JAVA_HOME"`
+  [ -n "$CLASSPATH" ] &&
+    CLASSPATH=`cygpath --path --unix "$CLASSPATH"`
+fi
+
+# For Mingw, ensure paths are in UNIX format before anything is touched
+if $mingw ; then
+  [ -n "$M2_HOME" ] &&
+    M2_HOME="`(cd "$M2_HOME"; pwd)`"
+  [ -n "$JAVA_HOME" ] &&
+    JAVA_HOME="`(cd "$JAVA_HOME"; pwd)`"
+fi
+
+if [ -z "$JAVA_HOME" ]; then
+  javaExecutable="`which javac`"
+  if [ -n "$javaExecutable" ] && ! [ "`expr \"$javaExecutable\" : '\([^ ]*\)'`" = "no" ]; then
+    # readlink(1) is not available as standard on Solaris 10.
+    readLink=`which readlink`
+    if [ ! `expr "$readLink" : '\([^ ]*\)'` = "no" ]; then
+      if $darwin ; then
+        javaHome="`dirname \"$javaExecutable\"`"
+        javaExecutable="`cd \"$javaHome\" && pwd -P`/javac"
+      else
+        javaExecutable="`readlink -f \"$javaExecutable\"`"
+      fi
+      javaHome="`dirname \"$javaExecutable\"`"
+      javaHome=`expr "$javaHome" : '\(.*\)/bin'`
+      JAVA_HOME="$javaHome"
+      export JAVA_HOME
+    fi
+  fi
+fi
+
+if [ -z "$JAVACMD" ] ; then
+  if [ -n "$JAVA_HOME"  ] ; then
+    if [ -x "$JAVA_HOME/jre/sh/java" ] ; then
+      # IBM's JDK on AIX uses strange locations for the executables
+      JAVACMD="$JAVA_HOME/jre/sh/java"
+    else
+      JAVACMD="$JAVA_HOME/bin/java"
+    fi
+  else
+    JAVACMD="`\\unset -f command; \\command -v java`"
+  fi
+fi
+
+if [ ! -x "$JAVACMD" ] ; then
+  echo "Error: JAVA_HOME is not defined correctly." >&2
+  echo "  We cannot execute $JAVACMD" >&2
+  exit 1
+fi
+
+if [ -z "$JAVA_HOME" ] ; then
+  echo "Warning: JAVA_HOME environment variable is not set."
+fi
+
+CLASSWORLDS_LAUNCHER=org.codehaus.plexus.classworlds.launcher.Launcher
+
+# traverses directory structure from process work directory to filesystem root
+# first directory with .mvn subdirectory is considered project base directory
+find_maven_basedir() {
+
+  if [ -z "$1" ]
+  then
+    echo "Path not specified to find_maven_basedir"
+    return 1
+  fi
+
+  basedir="$1"
+  wdir="$1"
+  while [ "$wdir" != '/' ] ; do
+    if [ -d "$wdir"/.mvn ] ; then
+      basedir=$wdir
+      break
+    fi
+    # workaround for JBEAP-8937 (on Solaris 10/Sparc)
+    if [ -d "${wdir}" ]; then
+      wdir=`cd "$wdir/.."; pwd`
+    fi
+    # end of workaround
+  done
+  echo "${basedir}"
+}
+
+# concatenates all lines of a file
+concat_lines() {
+  if [ -f "$1" ]; then
+    echo "$(tr -s '\n' ' ' < "$1")"
+  fi
+}
+
+BASE_DIR=`find_maven_basedir "$(pwd)"`
+if [ -z "$BASE_DIR" ]; then
+  exit 1;
+fi
+
+##########################################################################################
+# Extension to allow automatically downloading the maven-wrapper.jar from Maven-central
+# This allows using the maven wrapper in projects that prohibit checking in binary data.
+##########################################################################################
+if [ -r "$BASE_DIR/.mvn/wrapper/maven-wrapper.jar" ]; then
+    if [ "$MVNW_VERBOSE" = true ]; then
+      echo "Found .mvn/wrapper/maven-wrapper.jar"
+    fi
+else
+    if [ "$MVNW_VERBOSE" = true ]; then
+      echo "Couldn't find .mvn/wrapper/maven-wrapper.jar, downloading it ..."
+    fi
+    if [ -n "$MVNW_REPOURL" ]; then
+      jarUrl="$MVNW_REPOURL/org/apache/maven/wrapper/maven-wrapper/3.1.0/maven-wrapper-3.1.0.jar"
+    else
+      jarUrl="https://repo.maven.apache.org/maven2/org/apache/maven/wrapper/maven-wrapper/3.1.0/maven-wrapper-3.1.0.jar"
+    fi
+    while IFS="=" read key value; do
+      case "$key" in (wrapperUrl) jarUrl="$value"; break ;;
+      esac
+    done < "$BASE_DIR/.mvn/wrapper/maven-wrapper.properties"
+    if [ "$MVNW_VERBOSE" = true ]; then
+      echo "Downloading from: $jarUrl"
+    fi
+    wrapperJarPath="$BASE_DIR/.mvn/wrapper/maven-wrapper.jar"
+    if $cygwin; then
+      wrapperJarPath=`cygpath --path --windows "$wrapperJarPath"`
+    fi
+
+    if command -v wget > /dev/null; then
+        if [ "$MVNW_VERBOSE" = true ]; then
+          echo "Found wget ... using wget"
+        fi
+        if [ -z "$MVNW_USERNAME" ] || [ -z "$MVNW_PASSWORD" ]; then
+            wget "$jarUrl" -O "$wrapperJarPath" || rm -f "$wrapperJarPath"
+        else
+            wget --http-user=$MVNW_USERNAME --http-password=$MVNW_PASSWORD "$jarUrl" -O "$wrapperJarPath" || rm -f "$wrapperJarPath"
+        fi
+    elif command -v curl > /dev/null; then
+        if [ "$MVNW_VERBOSE" = true ]; then
+          echo "Found curl ... using curl"
+        fi
+        if [ -z "$MVNW_USERNAME" ] || [ -z "$MVNW_PASSWORD" ]; then
+            curl -o "$wrapperJarPath" "$jarUrl" -f
+        else
+            curl --user $MVNW_USERNAME:$MVNW_PASSWORD -o "$wrapperJarPath" "$jarUrl" -f
+        fi
+
+    else
+        if [ "$MVNW_VERBOSE" = true ]; then
+          echo "Falling back to using Java to download"
+        fi
+        javaClass="$BASE_DIR/.mvn/wrapper/MavenWrapperDownloader.java"
+        # For Cygwin, switch paths to Windows format before running javac
+        if $cygwin; then
+          javaClass=`cygpath --path --windows "$javaClass"`
+        fi
+        if [ -e "$javaClass" ]; then
+            if [ ! -e "$BASE_DIR/.mvn/wrapper/MavenWrapperDownloader.class" ]; then
+                if [ "$MVNW_VERBOSE" = true ]; then
+                  echo " - Compiling MavenWrapperDownloader.java ..."
+                fi
+                # Compiling the Java class
+                ("$JAVA_HOME/bin/javac" "$javaClass")
+            fi
+            if [ -e "$BASE_DIR/.mvn/wrapper/MavenWrapperDownloader.class" ]; then
+                # Running the downloader
+                if [ "$MVNW_VERBOSE" = true ]; then
+                  echo " - Running MavenWrapperDownloader.java ..."
+                fi
+                ("$JAVA_HOME/bin/java" -cp .mvn/wrapper MavenWrapperDownloader "$MAVEN_PROJECTBASEDIR")
+            fi
+        fi
+    fi
+fi
+##########################################################################################
+# End of extension
+##########################################################################################
+
+export MAVEN_PROJECTBASEDIR=${MAVEN_BASEDIR:-"$BASE_DIR"}
+if [ "$MVNW_VERBOSE" = true ]; then
+  echo $MAVEN_PROJECTBASEDIR
+fi
+MAVEN_OPTS="$(concat_lines "$MAVEN_PROJECTBASEDIR/.mvn/jvm.config") $MAVEN_OPTS"
+
+# For Cygwin, switch paths to Windows format before running java
+if $cygwin; then
+  [ -n "$M2_HOME" ] &&
+    M2_HOME=`cygpath --path --windows "$M2_HOME"`
+  [ -n "$JAVA_HOME" ] &&
+    JAVA_HOME=`cygpath --path --windows "$JAVA_HOME"`
+  [ -n "$CLASSPATH" ] &&
+    CLASSPATH=`cygpath --path --windows "$CLASSPATH"`
+  [ -n "$MAVEN_PROJECTBASEDIR" ] &&
+    MAVEN_PROJECTBASEDIR=`cygpath --path --windows "$MAVEN_PROJECTBASEDIR"`
+fi
+
+# Provide a "standardized" way to retrieve the CLI args that will
+# work with both Windows and non-Windows executions.
+MAVEN_CMD_LINE_ARGS="$MAVEN_CONFIG $@"
+export MAVEN_CMD_LINE_ARGS
+
+WRAPPER_LAUNCHER=org.apache.maven.wrapper.MavenWrapperMain
+
+exec "$JAVACMD" \
+  $MAVEN_OPTS \
+  $MAVEN_DEBUG_OPTS \
+  -classpath "$MAVEN_PROJECTBASEDIR/.mvn/wrapper/maven-wrapper.jar" \
+  "-Dmaven.home=${M2_HOME}" \
+  "-Dmaven.multiModuleProjectDirectory=${MAVEN_PROJECTBASEDIR}" \
+  ${WRAPPER_LAUNCHER} $MAVEN_CONFIG "$@"

mvnw.cmd

+@REM ----------------------------------------------------------------------------
+@REM Licensed to the Apache Software Foundation (ASF) under one
+@REM or more contributor license agreements.  See the NOTICE file
+@REM distributed with this work for additional information
+@REM regarding copyright ownership.  The ASF licenses this file
+@REM to you under the Apache License, Version 2.0 (the
+@REM "License"); you may not use this file except in compliance
+@REM with the License.  You may obtain a copy of the License at
+@REM
+@REM    https://www.apache.org/licenses/LICENSE-2.0
+@REM
+@REM Unless required by applicable law or agreed to in writing,
+@REM software distributed under the License is distributed on an
+@REM "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+@REM KIND, either express or implied.  See the License for the
+@REM specific language governing permissions and limitations
+@REM under the License.
+@REM ----------------------------------------------------------------------------
+
+@REM ----------------------------------------------------------------------------
+@REM Maven Start Up Batch script
+@REM
+@REM Required ENV vars:
+@REM JAVA_HOME - location of a JDK home dir
+@REM
+@REM Optional ENV vars
+@REM M2_HOME - location of maven2's installed home dir
+@REM MAVEN_BATCH_ECHO - set to 'on' to enable the echoing of the batch commands
+@REM MAVEN_BATCH_PAUSE - set to 'on' to wait for a keystroke before ending
+@REM MAVEN_OPTS - parameters passed to the Java VM when running Maven
+@REM     e.g. to debug Maven itself, use
+@REM set MAVEN_OPTS=-Xdebug -Xrunjdwp:transport=dt_socket,server=y,suspend=y,address=8000
+@REM MAVEN_SKIP_RC - flag to disable loading of mavenrc files
+@REM ----------------------------------------------------------------------------
+
+@REM Begin all REM lines with '@' in case MAVEN_BATCH_ECHO is 'on'
+@echo off
+@REM set title of command window
+title %0
+@REM enable echoing by setting MAVEN_BATCH_ECHO to 'on'
+@if "%MAVEN_BATCH_ECHO%" == "on"  echo %MAVEN_BATCH_ECHO%
+
+@REM set %HOME% to equivalent of $HOME
+if "%HOME%" == "" (set "HOME=%HOMEDRIVE%%HOMEPATH%")
+
+@REM Execute a user defined script before this one
+if not "%MAVEN_SKIP_RC%" == "" goto skipRcPre
+@REM check for pre script, once with legacy .bat ending and once with .cmd ending
+if exist "%USERPROFILE%\mavenrc_pre.bat" call "%USERPROFILE%\mavenrc_pre.bat" %*
+if exist "%USERPROFILE%\mavenrc_pre.cmd" call "%USERPROFILE%\mavenrc_pre.cmd" %*
+:skipRcPre
+
+@setlocal
+
+set ERROR_CODE=0
+
+@REM To isolate internal variables from possible post scripts, we use another setlocal
+@setlocal
+
+@REM ==== START VALIDATION ====
+if not "%JAVA_HOME%" == "" goto OkJHome
+
+echo.
+echo Error: JAVA_HOME not found in your environment. >&2
+echo Please set the JAVA_HOME variable in your environment to match the >&2
+echo location of your Java installation. >&2
+echo.
+goto error
+
+:OkJHome
+if exist "%JAVA_HOME%\bin\java.exe" goto init
+
+echo.
+echo Error: JAVA_HOME is set to an invalid directory. >&2
+echo JAVA_HOME = "%JAVA_HOME%" >&2
+echo Please set the JAVA_HOME variable in your environment to match the >&2
+echo location of your Java installation. >&2
+echo.
+goto error
+
+@REM ==== END VALIDATION ====
+
+:init
+
+@REM Find the project base dir, i.e. the directory that contains the folder ".mvn".
+@REM Fallback to current working directory if not found.
+
+set MAVEN_PROJECTBASEDIR=%MAVEN_BASEDIR%
+IF NOT "%MAVEN_PROJECTBASEDIR%"=="" goto endDetectBaseDir
+
+set EXEC_DIR=%CD%
+set WDIR=%EXEC_DIR%
+:findBaseDir
+IF EXIST "%WDIR%"\.mvn goto baseDirFound
+cd ..
+IF "%WDIR%"=="%CD%" goto baseDirNotFound
+set WDIR=%CD%
+goto findBaseDir
+
+:baseDirFound
+set MAVEN_PROJECTBASEDIR=%WDIR%
+cd "%EXEC_DIR%"
+goto endDetectBaseDir
+
+:baseDirNotFound
+set MAVEN_PROJECTBASEDIR=%EXEC_DIR%
+cd "%EXEC_DIR%"
+
+:endDetectBaseDir
+
+IF NOT EXIST "%MAVEN_PROJECTBASEDIR%\.mvn\jvm.config" goto endReadAdditionalConfig
+
+@setlocal EnableExtensions EnableDelayedExpansion
+for /F "usebackq delims=" %%a in ("%MAVEN_PROJECTBASEDIR%\.mvn\jvm.config") do set JVM_CONFIG_MAVEN_PROPS=!JVM_CONFIG_MAVEN_PROPS! %%a
+@endlocal & set JVM_CONFIG_MAVEN_PROPS=%JVM_CONFIG_MAVEN_PROPS%
+
+:endReadAdditionalConfig
+
+SET MAVEN_JAVA_EXE="%JAVA_HOME%\bin\java.exe"
+set WRAPPER_JAR="%MAVEN_PROJECTBASEDIR%\.mvn\wrapper\maven-wrapper.jar"
+set WRAPPER_LAUNCHER=org.apache.maven.wrapper.MavenWrapperMain
+
+set DOWNLOAD_URL="https://repo.maven.apache.org/maven2/org/apache/maven/wrapper/maven-wrapper/3.1.0/maven-wrapper-3.1.0.jar"
+
+FOR /F "usebackq tokens=1,2 delims==" %%A IN ("%MAVEN_PROJECTBASEDIR%\.mvn\wrapper\maven-wrapper.properties") DO (
+    IF "%%A"=="wrapperUrl" SET DOWNLOAD_URL=%%B
+)
+
+@REM Extension to allow automatically downloading the maven-wrapper.jar from Maven-central
+@REM This allows using the maven wrapper in projects that prohibit checking in binary data.
+if exist %WRAPPER_JAR% (
+    if "%MVNW_VERBOSE%" == "true" (
+        echo Found %WRAPPER_JAR%
+    )
+) else (
+    if not "%MVNW_REPOURL%" == "" (
+        SET DOWNLOAD_URL="%MVNW_REPOURL%/org/apache/maven/wrapper/maven-wrapper/3.1.0/maven-wrapper-3.1.0.jar"
+    )
+    if "%MVNW_VERBOSE%" == "true" (
+        echo Couldn't find %WRAPPER_JAR%, downloading it ...
+        echo Downloading from: %DOWNLOAD_URL%
+    )
+
+    powershell -Command "&{"^
+		"$webclient = new-object System.Net.WebClient;"^
+		"if (-not ([string]::IsNullOrEmpty('%MVNW_USERNAME%') -and [string]::IsNullOrEmpty('%MVNW_PASSWORD%'))) {"^
+		"$webclient.Credentials = new-object System.Net.NetworkCredential('%MVNW_USERNAME%', '%MVNW_PASSWORD%');"^
+		"}"^
+		"[Net.ServicePointManager]::SecurityProtocol = [Net.SecurityProtocolType]::Tls12; $webclient.DownloadFile('%DOWNLOAD_URL%', '%WRAPPER_JAR%')"^
+		"}"
+    if "%MVNW_VERBOSE%" == "true" (
+        echo Finished downloading %WRAPPER_JAR%
+    )
+)
+@REM End of extension
+
+@REM Provide a "standardized" way to retrieve the CLI args that will
+@REM work with both Windows and non-Windows executions.
+set MAVEN_CMD_LINE_ARGS=%*
+
+%MAVEN_JAVA_EXE% ^
+  %JVM_CONFIG_MAVEN_PROPS% ^
+  %MAVEN_OPTS% ^
+  %MAVEN_DEBUG_OPTS% ^
+  -classpath %WRAPPER_JAR% ^
+  "-Dmaven.multiModuleProjectDirectory=%MAVEN_PROJECTBASEDIR%" ^
+  %WRAPPER_LAUNCHER% %MAVEN_CONFIG% %*
+if ERRORLEVEL 1 goto error
+goto end
+
+:error
+set ERROR_CODE=1
+
+:end
+@endlocal & set ERROR_CODE=%ERROR_CODE%
+
+if not "%MAVEN_SKIP_RC%"=="" goto skipRcPost
+@REM check for post script, once with legacy .bat ending and once with .cmd ending
+if exist "%USERPROFILE%\mavenrc_post.bat" call "%USERPROFILE%\mavenrc_post.bat"
+if exist "%USERPROFILE%\mavenrc_post.cmd" call "%USERPROFILE%\mavenrc_post.cmd"
+:skipRcPost
+
+@REM pause the script if MAVEN_BATCH_PAUSE is set to 'on'
+if "%MAVEN_BATCH_PAUSE%"=="on" pause
+
+if "%MAVEN_TERMINATE_CMD%"=="on" exit %ERROR_CODE%
+
+cmd /C exit /B %ERROR_CODE%

pom.xml

+<project xmlns="http://maven.apache.org/POM/4.0.0"
+    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+    xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+ 
+    <parent>
+        <groupId>org.springframework.boot</groupId>
+        <artifactId>spring-boot-starter-parent</artifactId>
+        <version>2.1.1.RELEASE</version>
+        <relativePath /> <!-- lookup parent from repository -->
+    </parent>
+ 
+    <groupId>com.techgeeknext</groupId>
+    <artifactId>spring-boot-webflux-example</artifactId>
+    <version>0.0.1-SNAPSHOT</version>
+    <packaging>jar</packaging>
+ 
+    <name>spring-boot-webflux-example</name>
+
+    <properties>
+        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
+        <java.version>1.8</java.version>
+    </properties>
+ 
+    <dependencies>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-webflux</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-data-mongodb-reactive</artifactId> 
+        </dependency>
+
+        <dependency>
+            <groupId>org.projectlombok</groupId>
+            <artifactId>lombok</artifactId>
+            <optional>true</optional>
+        </dependency>
+
+        <dependency>
+            <groupId>javax.xml.bind</groupId>
+            <artifactId>jaxb-api</artifactId>
+            <version>2.3.0</version> 
+        </dependency>
+        <dependency>
+            <groupId>javax.servlet</groupId>
+            <artifactId>javax.servlet-api</artifactId>
+            <version>3.1.0</version>
+            <scope>provided</scope>
+        </dependency>
+        
+        <dependency>
+			<groupId>org.springframework.boot</groupId>
+			<artifactId>spring-boot-starter-test</artifactId>
+			<scope>test</scope>
+		</dependency>
+		<dependency>
+			<groupId>io.projectreactor</groupId>
+			<artifactId>reactor-test</artifactId>
+			<scope>test</scope>
+		</dependency>
+		
+		<!-- https://mvnrepository.com/artifact/junit/junit -->
+<dependency>
+    <groupId>junit</groupId>
+    <artifactId>junit</artifactId>
+    <version>4.13.2</version>
+    <scope>test</scope>
+</dependency>
+
+<dependency>
+			<groupId>org.springframework.boot</groupId>
+			<artifactId>spring-boot-starter-data-jpa</artifactId>
+		</dependency>
+		
+    </dependencies>
+ 
+</project>
\ No newline at end of file

src/main/java/com/nisum/Webflux/WebfluxApplication.java

+package com.nisum.Webflux;
+
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+
+@SpringBootApplication
+public class WebfluxApplication {
+
+	public static void main(String[] args) {
+		SpringApplication.run(WebfluxApplication.class, args);
+	}
+
+}

src/main/java/com/nisum/Webflux/client/StudentClient.java

+package com.nisum.Webflux.client;
+
+import org.springframework.http.MediaType;
+import org.springframework.stereotype.Component;
+import org.springframework.web.reactive.function.client.WebClient;
+
+import com.nisum.Webflux.model.Student;
+
+import reactor.core.publisher.Flux;
+import reactor.core.publisher.Mono;
+
+@Component
+public class StudentClient {
+
+	WebClient client = WebClient.create("http://localhost:8080");
+
+	public Flux<Student> getAllStudents() {
+		return client.get().uri("/students/getAll").accept(MediaType.APPLICATION_JSON).retrieve()
+				.bodyToFlux(Student.class);
+	}
+
+	public Mono<Student> getStudent(Long studentId) {
+		WebClient client = WebClient.create("http://localhost:8080");
+
+		Mono<Student> result = client.get().uri("/student/{id}", studentId).accept(MediaType.APPLICATION_JSON)
+				.retrieve().bodyToMono(Student.class);
+		return result;
+	}
+	
+
+}

src/main/java/com/nisum/Webflux/config/MongoDBConfig.java

+package com.nisum.Webflux.config;
+
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.data.mongodb.config.AbstractReactiveMongoConfiguration;
+import org.springframework.data.mongodb.core.ReactiveMongoTemplate;
+import org.springframework.data.mongodb.repository.config.EnableMongoRepositories;
+
+import com.mongodb.reactivestreams.client.MongoClient;
+import com.mongodb.reactivestreams.client.MongoClients;
+
+@Configuration
+@EnableMongoRepositories(basePackages = "com.nisum.Webflux.dao")
+public class MongoDBConfig extends AbstractReactiveMongoConfiguration {
+
+	@Value("${database.name}")
+	private String databaseName;
+
+	@Value("${database.host}")
+	private String databaseHost;
+
+	@Override
+	protected String getDatabaseName() {
+		return databaseName;
+	}
+
+	@Override
+	public MongoClient reactiveMongoClient() {
+		String name = databaseHost;
+		return MongoClients.create(name);
+	}
+
+	@Bean
+	public ReactiveMongoTemplate reactiveMongoTemplate() {
+		return new ReactiveMongoTemplate(reactiveMongoClient(), getDatabaseName());
+	}
+
+}

src/main/java/com/nisum/Webflux/config/RouterConfig.java

+package com.nisum.Webflux.config;
+
+import static org.springframework.web.reactive.function.server.RequestPredicates.GET;
+import static org.springframework.web.reactive.function.server.RequestPredicates.POST;
+import static org.springframework.web.reactive.function.server.RequestPredicates.accept;
+import static org.springframework.web.reactive.function.server.RequestPredicates.contentType;
+import static org.springframework.web.reactive.function.server.RouterFunctions.route;
+
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.http.MediaType;
+import org.springframework.web.reactive.function.server.RouterFunction;
+import org.springframework.web.reactive.function.server.ServerResponse;
+
+import com.nisum.Webflux.handler.StudentHandler;
+
+@Configuration
+public class RouterConfig {
+
+	@Bean
+	RouterFunction<ServerResponse> routes(StudentHandler handler) {
+		return route(GET("/students/getAll").and(accept(MediaType.APPLICATION_JSON)), handler::getAllStudents)
+				.andRoute(GET("/students/getById/{id}").and(contentType(MediaType.APPLICATION_JSON)), handler::getById)
+				.andRoute(POST("/students/create").and(accept(MediaType.APPLICATION_JSON)), handler::create);
+	}
+
+}

src/main/java/com/nisum/Webflux/config/WebFluxConfig.java

+package com.nisum.Webflux.config;
+
+import org.springframework.context.annotation.Configuration;
+import org.springframework.web.reactive.config.EnableWebFlux;
+import org.springframework.web.reactive.config.WebFluxConfigurer;
+
+@Configuration
+@EnableWebFlux
+public class WebFluxConfig implements WebFluxConfigurer
+{  
+}
\ No newline at end of file

src/main/java/com/nisum/Webflux/controller/AddressController.java

+package com.nisum.Webflux.controller;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import com.nisum.Webflux.model.Address;
+import com.nisum.Webflux.service.AddressService;
+
+import reactor.core.publisher.Flux;
+import reactor.core.publisher.Mono;
+
+@RestController
+@RequestMapping("/address")
+public class AddressController {
+
+	@Autowired
+	private AddressService addressService;
+
+	@PostMapping("/create")
+	Mono<Address> createAddress(@RequestBody Address address) {
+		return addressService.createAddress(address);
+	}
+
+	@GetMapping("/getAll")
+	private Flux<Address> getAllStudents() {
+		return addressService.getAll();
+	}
+}

src/main/java/com/nisum/Webflux/controller/StudentController.java

+package com.nisum.Webflux.controller;
+
+import java.util.List;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.PutMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import com.nisum.Webflux.dto.StudentDTO;
+import com.nisum.Webflux.model.Address;
+import com.nisum.Webflux.model.Student;
+import com.nisum.Webflux.model.Subject;
+import com.nisum.Webflux.service.StudentService;
+
+import reactor.core.publisher.Flux;
+import reactor.core.publisher.Mono;
+import reactor.util.function.Tuple3;
+
+@RestController
+@RequestMapping("/student")
+public class StudentController {
+
+	@Autowired
+	private StudentService studentService;
+
+	@PostMapping("/create")
+	private Mono<Student> createStudent(@RequestBody StudentDTO student) {
+		return studentService.createStudent(student);
+	}
+
+	@PutMapping("/update")
+	private Mono<Student> updateStudent(@RequestBody StudentDTO student) {
+		return studentService.createStudent(student);
+	}
+
+	@GetMapping("/getById/{studentId}")
+	private Mono<Student> getStudentById(@PathVariable String studentId) {
+		System.out.println("studentId="+studentId);
+		return studentService.findById(Long.valueOf(studentId));
+		//return new ResponseEntity<Mono<Student>>(student, student != null ? HttpStatus.OK : HttpStatus.NOT_FOUND);
+	}
+
+	@GetMapping("/getAll")
+	private Flux<StudentDTO> getAllStudents() {
+		return studentService.getAllStudents();
+	}
+
+	@GetMapping("/searchNames/{name}")
+	private Flux<Student> getStudentsByName(@PathVariable String name) {
+		return studentService.getStudentsByName(name);
+	}
+
+	@GetMapping("/searchNamesByOrder/{name}")
+	public Flux<Student> searchStudents(@PathVariable String name) {
+		return studentService.fetchStudents(name);
+	}
+	
+	@GetMapping("/searchNamesWithZip/{studentId}")
+	private Mono<Tuple3<Student, List<Address>, List<Subject>>> getStudentsByNames(@PathVariable String studentId) {
+		return studentService.zipWith(Long.valueOf(studentId));
+	}
+	
+	
+	@GetMapping("/getMapResults")
+	private Flux<String> getMap() {
+		return studentService.transformMap();
+	}
+
+	@GetMapping("/getFlatMapResults")
+	private Flux<String> getFlatMap() {
+		return studentService.transformUsingFlatMap();
+	}
+
+	@GetMapping("/getMergeResults")
+	private Flux<String> getMerge() {
+		return studentService.combineUsingMerge();
+	}
+
+	@GetMapping("/getConcatResults")
+	private Flux<String> getConcat() {
+		return studentService.concat();
+	}
+
+	@GetMapping("/getZipResults")
+	private Flux<String> getZip() {
+		return studentService.combineWithZip();
+	}
+
+}

src/main/java/com/nisum/Webflux/controller/SubjectController.java

+package com.nisum.Webflux.controller;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import com.nisum.Webflux.model.Subject;
+import com.nisum.Webflux.service.SubjectService;
+
+import reactor.core.publisher.Flux;
+import reactor.core.publisher.Mono;
+
+@RestController
+@RequestMapping("/subject")
+public class SubjectController {
+
+	@Autowired
+	private SubjectService subjectService;
+
+	@PostMapping("/create")
+	Mono<Subject> createSubject(@RequestBody Subject subject) {
+
+		return subjectService.createSubject(subject);
+	}
+
+	@GetMapping("/getAll")
+	private Flux<Subject> getAllSubjects() {
+		return subjectService.getAll();
+	}
+
+}

src/main/java/com/nisum/Webflux/controller/TeacherController.java

+package com.nisum.Webflux.controller;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RestController;
+
+import com.nisum.Webflux.model.Teacher;
+import com.nisum.Webflux.service.TeacherService;
+
+import reactor.core.publisher.Flux;
+import reactor.core.publisher.Mono;
+
+@RestController
+public class TeacherController {
+	
+	@Autowired
+	private TeacherService teacherService;
+	
+	@PostMapping("/create")
+	Mono<Teacher> createTeacher(@RequestBody Teacher address) {
+		return teacherService.createAddress(address);
+	}
+
+	@GetMapping("/getAll")
+	private Flux<Teacher> getAllTeachers() {
+		return teacherService.getAll();
+	}
+
+}

src/main/java/com/nisum/Webflux/dao/AddressRepository.java

+package com.nisum.Webflux.dao;
+
+import org.springframework.data.mongodb.repository.ReactiveMongoRepository;
+import org.springframework.stereotype.Repository;
+
+import com.nisum.Webflux.model.Address;
+
+import reactor.core.publisher.Flux;
+
+@Repository
+public interface AddressRepository extends ReactiveMongoRepository<Address, Long>{
+
+	Flux<Address> findByStudentId(Long studentId);
+}

src/main/java/com/nisum/Webflux/dao/StudentRepository.java

+package com.nisum.Webflux.dao;
+
+import org.springframework.data.mongodb.repository.ReactiveMongoRepository;
+import org.springframework.stereotype.Repository;
+
+import com.nisum.Webflux.model.Student;
+
+import reactor.core.publisher.Flux;
+
+@Repository
+public interface StudentRepository extends ReactiveMongoRepository<Student, Long>{
+
+	Flux<Student> findByFirstName(String n);
+
+}

src/main/java/com/nisum/Webflux/dao/SubjectRepository.java

+package com.nisum.Webflux.dao;
+
+import org.springframework.data.mongodb.repository.ReactiveMongoRepository;
+import org.springframework.stereotype.Repository;
+
+import com.nisum.Webflux.model.Subject;
+
+import reactor.core.publisher.Flux;
+
+@Repository
+public interface SubjectRepository extends ReactiveMongoRepository<Subject, Long>{
+
+	Flux<Subject> findByStudentId(Long studentId);
+}

src/main/java/com/nisum/Webflux/dao/TeacherRepository.java

+package com.nisum.Webflux.dao;
+
+import org.springframework.data.mongodb.repository.ReactiveMongoRepository;
+import org.springframework.stereotype.Repository;
+
+import com.nisum.Webflux.model.Teacher;
+
+@Repository
+public interface TeacherRepository extends ReactiveMongoRepository<Teacher, Long>{
+
+}

src/main/java/com/nisum/Webflux/dto/StudentDTO.java

+package com.nisum.Webflux.dto;
+
+import java.util.List;
+
+import com.nisum.Webflux.model.Address;
+import com.nisum.Webflux.model.Subject;
+
+public class StudentDTO {
+
+	private Long id;
+	private String firstName;
+	private String lastName;
+	private String age;
+	private List<String> phoneNumbers;
+	private List<Address> addresses;
+	private List<Subject> subjects;
+
+	public Long getId() {
+		return id;
+	}
+
+	public void setId(Long id) {
+		this.id = id;
+	}
+
+	public String getFirstName() {
+		return firstName;
+	}
+
+	public void setFirstName(String firstName) {
+		this.firstName = firstName;
+	}
+
+	public String getLastName() {
+		return lastName;
+	}
+
+	public void setLastName(String lastName) {
+		this.lastName = lastName;
+	}
+
+	public String getAge() {
+		return age;
+	}
+
+	public void setAge(String age) {
+		this.age = age;
+	}
+
+	public List<String> getPhoneNumbers() {
+		return phoneNumbers;
+	}
+
+	public void setPhoneNumbers(List<String> phoneNumbers) {
+		this.phoneNumbers = phoneNumbers;
+	}
+
+	public List<Address> getAddresses() {
+		return addresses;
+	}
+
+	public void setAddresses(List<Address> addresses) {
+		this.addresses = addresses;
+	}
+
+	public List<Subject> getSubjects() {
+		return subjects;
+	}
+
+	public void setSubjects(List<Subject> subjects) {
+		this.subjects = subjects;
+	}
+
+}

src/main/java/com/nisum/Webflux/handler/StudentHandler.java

+package com.nisum.Webflux.handler;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.MediaType;
+import org.springframework.stereotype.Component;
+import org.springframework.web.reactive.function.server.ServerRequest;
+import org.springframework.web.reactive.function.server.ServerResponse;
+
+import com.nisum.Webflux.dto.StudentDTO;
+import com.nisum.Webflux.model.Student;
+import com.nisum.Webflux.service.StudentService;
+
+import lombok.RequiredArgsConstructor;
+import reactor.core.publisher.Mono;
+
+@Component
+@RequiredArgsConstructor
+public class StudentHandler {
+
+	@Autowired
+	private StudentService studentService;
+
+	public Mono<ServerResponse> getAllStudents(ServerRequest serverRequest) {
+		return ServerResponse.ok().contentType(MediaType.APPLICATION_JSON).body(studentService.getAllStudentsRouting(),
+				Student.class);
+	}
+
+	public Mono<ServerResponse> getById(ServerRequest request) {
+		String id = request.pathVariable("getById");
+		Mono<Student> student = request.bodyToMono(Student.class);
+		return student
+				.flatMap(st -> ServerResponse.ok().body(studentService.findById(Long.valueOf(id)), Student.class));
+	}
+
+	public Mono<ServerResponse> create(ServerRequest request) {
+		Mono<StudentDTO> student = request.bodyToMono(StudentDTO.class);
+
+		return student.flatMap(std -> ServerResponse.ok().body(studentService.createStudent(std), Student.class));
+
+	}
+}

src/main/java/com/nisum/Webflux/model/Address.java

+package com.nisum.Webflux.model;
+
+import org.springframework.data.annotation.Id;
+import org.springframework.data.mongodb.core.mapping.Document;
+
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+@AllArgsConstructor
+@NoArgsConstructor
+@Data
+@Document
+public class Address {
+
+	@Id
+	private Long id;
+	private String address;
+	private String city;
+	private String pincode;
+	private String addressType;
+	private Long studentId;
+
+	public Long getId() {
+		return id;
+	}
+
+	public void setId(Long id) {
+		this.id = id;
+	}
+
+	public String getAddress() {
+		return address;
+	}
+
+	public void setAddress(String address) {
+		this.address = address;
+	}
+
+	public String getCity() {
+		return city;
+	}
+
+	public void setCity(String city) {
+		this.city = city;
+	}
+
+	public String getPincode() {
+		return pincode;
+	}
+
+	public void setPincode(String pincode) {
+		this.pincode = pincode;
+	}
+
+	public String getAddressType() {
+		return addressType;
+	}
+
+	public void setAddressType(String addressType) {
+		this.addressType = addressType;
+	}
+
+	public Long getStudentId() {
+		return studentId;
+	}
+
+	public void setStudentId(Long studentId) {
+		this.studentId = studentId;
+	}
+
+}

src/main/java/com/nisum/Webflux/model/Employee.java

+package com.nisum.Webflux.model;
+
+import javax.persistence.Column;
+import javax.persistence.Entity;
+import javax.persistence.GeneratedValue;
+import javax.persistence.GenerationType;
+import javax.persistence.Table;
+
+import org.springframework.data.annotation.Id;
+
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+import lombok.Setter;
+
+@Setter
+@Getter
+@AllArgsConstructor
+@NoArgsConstructor
+@Builder
+
+@Entity
+@Table(name = "employees")
+public class Employee {
+
+    @Id
+    @GeneratedValue(strategy = GenerationType.IDENTITY)
+    private long id;
+
+    @Column(name = "first_name", nullable = false)
+    private String firstName;
+
+    @Column(name = "last_name", nullable = false)
+    private String lastName;
+
+    @Column(nullable = false)
+    private String email;
+}
\ No newline at end of file

src/main/java/com/nisum/Webflux/model/Student.java

+package com.nisum.Webflux.model;
+
+import java.util.List;
+
+import org.springframework.data.annotation.Id;
+import org.springframework.data.annotation.Transient;
+import org.springframework.data.mongodb.core.mapping.Document;
+
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+@NoArgsConstructor
+@AllArgsConstructor
+@Document
+@Data
+public class Student {
+
+	@Transient
+	public static final String SEQUENCE_NAME = "users_sequence";
+
+	@Id
+	private Long id;
+	private String firstName;
+	private String lastName;
+	private String age;
+	private List<String> phoneNumbers;
+	
+	private List<Address> address;
+	
+	private List<Subject> subjects;
+
+	public Long getId() {
+		return id;
+	}
+
+	public void setId(Long id) {
+		this.id = id;
+	}
+
+	public String getFirstName() {
+		return firstName;
+	}
+
+	public void setFirstName(String firstName) {
+		this.firstName = firstName;
+	}
+
+	public String getLastName() {
+		return lastName;
+	}
+
+	public void setLastName(String lastName) {
+		this.lastName = lastName;
+	}
+
+	public String getAge() {
+		return age;
+	}
+
+	public void setAge(String age) {
+		this.age = age;
+	}
+
+	public List<String> getPhoneNumbers() {
+		return phoneNumbers;
+	}
+
+	public void setPhoneNumbers(List<String> phoneNumbers) {
+		this.phoneNumbers = phoneNumbers;
+	}
+
+	public List<Address> getAddress() {
+		return address;
+	}
+
+	public void setAddress(List<Address> address) {
+		this.address = address;
+	}
+
+	public List<Subject> getSubjects() {
+		return subjects;
+	}
+
+	public void setSubjects(List<Subject> subjects) {
+		this.subjects = subjects;
+	}
+
+}

src/main/java/com/nisum/Webflux/model/Subject.java

+package com.nisum.Webflux.model;
+
+import org.springframework.data.annotation.Id;
+import org.springframework.data.mongodb.core.mapping.Document;
+
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+@AllArgsConstructor
+@NoArgsConstructor
+@Document
+@Data
+public class Subject {
+
+	@Id
+	private Long id;
+	private String subjectName;
+	private Long studentId;
+
+	public Long getId() {
+		return id;
+	}
+
+	public void setId(Long id) {
+		this.id = id;
+	}
+
+	public String getSubjectName() {
+		return subjectName;
+	}
+
+	public void setSubjectName(String subjectName) {
+		this.subjectName = subjectName;
+	}
+
+	public Long getStudentId() {
+		return studentId;
+	}
+
+	public void setStudentId(Long studentId) {
+		this.studentId = studentId;
+	}
+
+}

src/main/java/com/nisum/Webflux/model/Teacher.java

+package com.nisum.Webflux.model;
+
+import java.util.List;
+
+import org.springframework.data.annotation.Id;
+import org.springframework.data.mongodb.core.mapping.Document;
+
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+@NoArgsConstructor
+@AllArgsConstructor
+@Document
+@Data
+public class Teacher {
+
+	
+	@Id
+	private Long id;
+	private String firstName;
+	private String lastName;
+	private String age;
+	private List<String> phoneNumbers;
+	
+	public Long getId() {
+		return id;
+	}
+	public void setId(Long id) {
+		this.id = id;
+	}
+	public String getFirstName() {
+		return firstName;
+	}
+	public void setFirstName(String firstName) {
+		this.firstName = firstName;
+	}
+	public String getLastName() {
+		return lastName;
+	}
+	public void setLastName(String lastName) {
+		this.lastName = lastName;
+	}
+	public String getAge() {
+		return age;
+	}
+	public void setAge(String age) {
+		this.age = age;
+	}
+	public List<String> getPhoneNumbers() {
+		return phoneNumbers;
+	}
+	public void setPhoneNumbers(List<String> phoneNumbers) {
+		this.phoneNumbers = phoneNumbers;
+	}
+	
+	
+}

src/main/java/com/nisum/Webflux/service/AddressService.java

+package com.nisum.Webflux.service;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import com.nisum.Webflux.dao.AddressRepository;
+import com.nisum.Webflux.model.Address;
+
+import reactor.core.publisher.Flux;
+import reactor.core.publisher.Mono;
+
+@Service
+public class AddressService {
+
+	@Autowired
+	private AddressRepository addressRepository;
+
+	public Mono<Address> createAddress(Address address) {
+		return addressRepository.save(address);
+	}
+
+	public Flux<Address> getAll() {
+		return addressRepository.findAll();
+	}
+
+	public Mono<Address> findById(Long id) {
+		return addressRepository.findById(id);
+	}
+
+}

src/main/java/com/nisum/Webflux/service/StudentService.java

+package com.nisum.Webflux.service;
+
+import java.util.ArrayList;
+import java.util.Arrays;
+import java.util.Collections;
+import java.util.List;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.domain.Sort;
+import org.springframework.data.mongodb.core.ReactiveMongoTemplate;
+import org.springframework.data.mongodb.core.query.Criteria;
+import org.springframework.data.mongodb.core.query.Query;
+import org.springframework.stereotype.Service;
+
+import com.nisum.Webflux.dao.AddressRepository;
+import com.nisum.Webflux.dao.StudentRepository;
+import com.nisum.Webflux.dao.SubjectRepository;
+import com.nisum.Webflux.dto.StudentDTO;
+import com.nisum.Webflux.model.Address;
+import com.nisum.Webflux.model.Student;
+import com.nisum.Webflux.model.Subject;
+
+import reactor.core.publisher.Flux;
+import reactor.core.publisher.Mono;
+import reactor.util.function.Tuple2;
+import reactor.util.function.Tuple3;
+import reactor.util.function.Tuples;
+
+@Service
+public class StudentService {
+
+	@Autowired
+	private StudentRepository studentRepository;
+
+	@Autowired
+	private ReactiveMongoTemplate reactiveMongoTemplate;
+
+	@Autowired
+	private AddressRepository addressRepository;
+
+	@Autowired
+	private SubjectRepository subjectRepository;
+
+	public Mono<Student> createStudent(StudentDTO studentDto) {
+
+		Student student = new Student();
+		student.setId(studentDto.getId());
+		student.setFirstName(studentDto.getFirstName());
+		student.setLastName(studentDto.getLastName());
+		student.setAge(studentDto.getAge());
+		student.setPhoneNumbers(studentDto.getPhoneNumbers());
+
+		Mono<Student> studentMono = studentRepository.save(student);
+		List<Address> addressList = new ArrayList<Address>();
+		List<Subject> subjectsList = new ArrayList<Subject>();
+		studentMono.subscribe(std -> {
+			studentDto.getAddresses().forEach(addr -> {
+				Address address = new Address();
+				address.setId(addr.getId());
+				address.setAddress(addr.getAddress());
+				address.setCity(addr.getCity());
+				address.setAddressType(addr.getAddressType());
+				address.setPincode(addr.getPincode());
+				address.setStudentId(std.getId());
+				addressList.add(address);
+
+//				Mono<Address> add = addressRepository.save(address);
+//				add.subscribe(a -> {
+//					System.out.println("address after saving==" + a.getAddress());
+//				});
+			});
+			studentDto.getSubjects().forEach(sub -> {
+				Subject subject = new Subject();
+				subject.setId(sub.getId());
+				subject.setSubjectName(sub.getSubjectName());
+				subject.setStudentId(std.getId());
+
+				subjectsList.add(subject);
+
+//				Mono<Subject> subMono = subjectRepository.save(subject);
+//				subMono.subscribe(a -> {
+//					System.out.println("address after saving==" + a.getSubjectName());
+//				});
+			});
+			 Flux<Address> allAddress = addressRepository.saveAll(addressList);
+			 Flux<Subject> allSubjects = subjectRepository.saveAll(subjectsList);
+		});
+		return studentMono;
+	}
+
+	public Mono<Student> updateStudent(Student student) {
+		return studentRepository.save(student);
+	}
+
+	public Flux<Address> getAddressByStudentId(Long studentId) {
+		return addressRepository.findByStudentId(studentId);
+	}
+
+	public Flux<StudentDTO> getAllStudents() {
+
+		Flux<StudentDTO> response = studentRepository.findAll().flatMap(std -> {
+
+			Flux<Address> address = addressRepository.findByStudentId(std.getId())
+					.switchIfEmpty(Flux.just(new Address()));
+
+			Flux<Subject> subjects = subjectRepository.findByStudentId(std.getId())
+					.switchIfEmpty(Flux.just(new Subject()));
+
+			StudentDTO dto = new StudentDTO();
+			dto.setId(std.getId());
+			dto.setFirstName(std.getFirstName());
+			dto.setLastName(std.getLastName());
+			dto.setAge(std.getAge());
+			dto.setPhoneNumbers(std.getPhoneNumbers());
+
+			dto.setAddresses(address.collectList().block());
+			dto.setSubjects(subjects.collectList().block());
+
+			Flux<StudentDTO> responseObject = Flux.just(dto);
+			return responseObject;
+		});
+
+		return response;
+	}
+
+	public Mono<Student> findById(Long id) {
+
+		Mono<Student> monoStudent = studentRepository.findById(id).zipWhen(stud -> {
+
+			Flux<Address> studentAddress = addressRepository.findByStudentId(stud.getId())
+					.switchIfEmpty(Flux.just(new Address()));
+
+			Flux<Subject> subjects = subjectRepository.findByStudentId(stud.getId())
+					.switchIfEmpty(Flux.just(new Subject()));
+
+			return studentAddress.collectList().zipWith(subjects.collectList());
+		}).map(tuple2 -> {
+			Student s = tuple2.getT1();
+
+			Tuple2<List<Address>, List<Subject>> stAddressAndSubjects = tuple2.getT2();
+
+			List<Address> stAddress = stAddressAndSubjects.getT1();
+			s.setAddress(stAddress);
+
+			List<Subject> stSubjects = stAddressAndSubjects.getT2();
+			s.setSubjects(stSubjects);
+
+			return s;
+		});
+
+		return monoStudent;
+	}
+
+	public Mono<Student> findByIdZipWhen(Long id) {
+		Mono<Student> student = studentRepository.findById(id).flatMap(
+				std -> Mono.just(std).zipWith(addressRepository.findByStudentId(std.getId()).collectList(), (st, a) -> {
+					st.setAddress(a);
+					return st;
+				}));
+
+		return student;
+	}
+
+	public Mono<Tuple2<Student, List<Address>>> zipWhen(Long studentId) {
+
+		Mono<Tuple2<Student, List<Address>>> monoStudent = studentRepository.findById(studentId).zipWhen(student -> {
+			Flux<Address> studentAddress = addressRepository.findByStudentId(student.getId());
+			return studentAddress.collectList();
+		});
+		return monoStudent;
+	}
+
+	public Mono<Tuple3<Student, List<Address>, List<Subject>>> zipWith(Long studentId) {
+
+		Mono<Tuple3<Student, List<Address>, List<Subject>>> stdWithAddressAndSubjects = studentRepository
+				.findById(studentId).zipWhen(stud -> {
+
+					Flux<Address> studentAddress = addressRepository.findByStudentId(stud.getId())
+							.switchIfEmpty(Flux.just(new Address()));
+
+					Flux<Subject> subjects = subjectRepository.findByStudentId(stud.getId())
+							.switchIfEmpty(Flux.just(new Subject()));
+
+					return studentAddress.collectList().zipWith(subjects.collectList());
+				}).map(tuple3 -> {
+
+					Student student = tuple3.getT1();
+
+					Tuple2<List<Address>, List<Subject>> stAddressAndSubjects = tuple3.getT2();
+
+					List<Address> stAddress = stAddressAndSubjects.getT1();
+
+					List<Subject> stSubjects = stAddressAndSubjects.getT2();
+
+					return Tuples.of(student, stAddress, stSubjects);
+				});
+		return stdWithAddressAndSubjects;
+	}
+
+	public Flux<Student> fetchStudents(String name) {
+		Query query = new Query().with(Sort.by(Collections.singletonList(Sort.Order.asc("age"))));
+		query.addCriteria(Criteria.where("firstName").regex(name));
+		return reactiveMongoTemplate.find(query, Student.class);
+	}
+
+	public Flux<Student> getStudentsByName(String name) {
+
+		String[] names = name.split(",");
+		Flux<Student> allStudents = Flux.fromArray(names).flatMap(n -> studentRepository.findByFirstName(n));
+		return allStudents;
+	}
+
+	public Flux<String> transformMap() {
+		List<String> names = Arrays.asList("google", "facebook", "Stackoverflow");
+		Flux<String> mapNames = Flux.fromIterable(names).filter(name -> name.length() > 5).map(n -> n.toUpperCase())
+				.log();
+		return mapNames;
+
+	}
+
+	public Flux<String> transformUsingFlatMap() {
+		List<String> names = Arrays.asList("google ", "abc", "fb", " stackoverflow");
+		Flux<String> names$ = Flux.fromIterable(names).filter(name -> name.length() > 5).flatMap(name -> {
+			return Mono.just(name.toUpperCase());
+		});
+		return names$;
+	}
+
+	public Flux<String> combineUsingMerge() {
+		Flux<String> names1$ = Flux.just("JP ", " Nisum ", "Tech ");
+		Flux<String> names2$ = Flux.just(" Morgan ", " Technologies ", " Mahindra");
+		Flux<String> names$ = Flux.merge(names1$, names2$).log();
+		
+		Flux<Student> students= Flux.merge(Flux.just(new Student()),Flux.just(new Student()));
+		return names$;
+	}
+
+	public Flux<String> concat() {
+		Flux<String> names1$ = Flux.just("JP ", " Nisum ", "Tech ");
+		Flux<String> names2$ = Flux.just("Morgan ", " Technologies ", " Mahindra");
+		Flux<String> names$ = Flux.concat(names1$, names2$).log();
+		return names$;
+	}
+
+	public Flux<String> combineWithZip() {
+		Flux<String> names1$ = Flux.just("JP ", " Nisum ", "Tech ");
+		Flux<String> names2$ = Flux.just("Morgan ", " Technologies ", " Mahindra");
+		Flux<String> names$ = Flux.zip(names1$, names2$, (n1, n2) -> {
+			return n1.concat(" ").concat(n2);
+		}).log();
+		
+//		Flux<StudentDTO> response = Flux.zip(students, studentAddresses, studentSubjects).flatMap(st -> {
+//			StudentDTO dto = new StudentDTO();
+//			System.out.println("st=="+st);
+//			dto.setFirstName(st.getT1().getFirstName());
+//			dto.setLastName(st.getT1().getLastName());
+//			dto.setAge(st.getT1().getAge());
+//			dto.setPhoneNumbers(st.getT1().getPhoneNumbers());
+//
+//			dto.setAddresses(studentAddresses.collectList().block());
+//			dto.setSubjects(studentSubjects.collectList().block());
+//
+//			Flux<StudentDTO> responseObject = Flux.just(dto);
+//			return responseObject;
+//		});
+		return names$;
+	}
+
+	public Flux<Student> getAllStudentsRouting() {
+
+		return studentRepository.findAll();
+	}
+	
+	public Flux<Tuple2<Tuple2<Student, Address>, Subject>> zipWith() {
+
+		Flux<Student> students = studentRepository.findAll();
+
+		Flux<Address> studentAddresses = students.flatMap(a -> addressRepository.findByStudentId(a.getId()))
+				.switchIfEmpty(Flux.just(new Address()));
+
+		Flux<Subject> studentSubjects = students.flatMap(a -> subjectRepository.findByStudentId(a.getId()))
+				.switchIfEmpty(Flux.just(new Subject()));
+
+		Flux<Tuple2<Student, Address>> studentsWithAddress = students.zipWith(studentAddresses);
+
+		studentsWithAddress.subscribe(std -> {
+			System.out.println("Name with Address==" + std.getT1().getFirstName() + "--" + std.getT2().getAddress());
+		});
+
+		Flux<Tuple2<Tuple2<Student, Address>, Subject>> studentsAndAddressWithSubjects = studentsWithAddress
+				.zipWith(studentSubjects);
+
+		studentsAndAddressWithSubjects.subscribe(std -> {
+			System.out.println(
+					"Name with Subject==" + std.getT1().getT1().getFirstName() + "--" + std.getT2().getSubjectName());
+		});
+
+		return studentsAndAddressWithSubjects;
+	}
+
+}

src/main/java/com/nisum/Webflux/service/SubjectService.java

+package com.nisum.Webflux.service;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import com.nisum.Webflux.dao.SubjectRepository;
+import com.nisum.Webflux.model.Subject;
+
+import reactor.core.publisher.Flux;
+import reactor.core.publisher.Mono;
+
+@Service
+public class SubjectService {
+
+	
+	@Autowired
+	private SubjectRepository subjectRepository;
+
+	public Mono<Subject> createSubject(Subject subject) {
+		return subjectRepository.save(subject);
+	}
+
+	public Flux<Subject> getAll() {
+		return subjectRepository.findAll();
+	}
+
+	public Mono<Subject> findById(Long id) {
+		return subjectRepository.findById(id);
+	}
+}

src/main/java/com/nisum/Webflux/service/TeacherService.java

+package com.nisum.Webflux.service;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import com.nisum.Webflux.dao.TeacherRepository;
+import com.nisum.Webflux.model.Teacher;
+
+import reactor.core.publisher.Flux;
+import reactor.core.publisher.Mono;
+
+@Service
+public class TeacherService {
+
+	@Autowired
+	private TeacherRepository teacherRepository;
+
+	public Mono<Teacher> createAddress(Teacher address) {
+		return teacherRepository.save(address);
+	}
+
+	public Flux<Teacher> getAll() {
+		return teacherRepository.findAll();
+	}
+
+	public Mono<Teacher> findById(Long id) {
+		return teacherRepository.findById(id);
+	}
+
+}

src/main/java/com/nisum/Webflux/utils/WebFluxUtils.java

+package com.nisum.Webflux.utils;
+
+import java.util.Optional;
+
+import reactor.core.publisher.Mono;
+
+public class WebFluxUtils {
+	
+	 public static <T> Mono<Optional<T>> optional(Mono<T> in) {
+	        return in.map(Optional::of).switchIfEmpty(Mono.just(Optional.empty()));
+	    }
+	 
+		
+}

src/main/resources/application.properties

+database.name= studentDB
+database.host = mongodb://localhost:27017/

src/test/java/com/nisum/Webflux/WebfluxApplicationTests.java

+package com.nisum.Webflux;
+
+import org.junit.Test;
+import org.springframework.boot.test.context.SpringBootTest;
+
+@SpringBootTest
+class WebfluxApplicationTests {
+
+	@Test
+	void contextLoads() {
+	}
+
+}