From b95b09c274090e2a63d58bc3aae160679fa98bfc Mon Sep 17 00:00:00 2001
From: Kumar Prabhash Anand <kumarprabhash1995@gmail.com>
Date: Thu, 6 Oct 2022 07:56:02 +0200
Subject: [PATCH] BAEL-5784 Added Flux Vs Mono Unit Tests (#12815)

---
 .../reactor/core/FluxVsMonoUnitTest.java      | 45 +++++++++++++++++++
 1 file changed, 45 insertions(+)
 create mode 100644 reactor-core/src/test/java/com/baeldung/reactor/core/FluxVsMonoUnitTest.java

diff --git a/reactor-core/src/test/java/com/baeldung/reactor/core/FluxVsMonoUnitTest.java b/reactor-core/src/test/java/com/baeldung/reactor/core/FluxVsMonoUnitTest.java
new file mode 100644
index 0000000000..a6a4110b3c
--- /dev/null
+++ b/reactor-core/src/test/java/com/baeldung/reactor/core/FluxVsMonoUnitTest.java
@@ -0,0 +1,45 @@
+package com.baeldung.reactor.core;
+
+import org.junit.jupiter.api.Test;
+
+import reactor.core.publisher.Flux;
+import reactor.core.publisher.Mono;
+import reactor.test.StepVerifier;
+
+public class FluxVsMonoUnitTest {
+
+    @Test
+    public void givenMonoPublisher_whenSubscribeThenReturnSingleValue() {
+        Mono<String> helloMono = Mono.just("Hello");
+        StepVerifier.create(helloMono)
+          .expectNext("Hello")
+          .expectComplete()
+          .verify();
+    }
+
+    @Test
+    public void givenFluxPublisher_whenSubscribeThenReturnMultipleValues() {
+        Flux<String> stringFlux = Flux.just("Hello", "Baeldung");
+        StepVerifier.create(stringFlux)
+          .expectNext("Hello")
+          .expectNext("Baeldung")
+          .expectComplete()
+          .verify();
+    }
+
+    @Test
+    public void givenFluxPublisher_whenSubscribeThenReturnMultipleValuesWithError() {
+        Flux<String> stringFlux = Flux.just("Hello", "Baeldung", "Error")
+          .map(str -> {
+              if (str.equals("Error"))
+                  throw new RuntimeException("Throwing Error");
+              return str;
+          });
+        StepVerifier.create(stringFlux)
+          .expectNext("Hello")
+          .expectNext("Baeldung")
+          .expectError()
+          .verify();
+    }
+
+}