From 3fb23280c91f29bf67af64d428566eaa4bab78d0 Mon Sep 17 00:00:00 2001
From: JinQuiet <Quester82@gmail.com>
Date: Thu, 16 Jun 2022 18:59:17 +0300
Subject: [PATCH] Replace "omit" for "emit" in the commentaries.

Replace "omit" for "emit" in the commentaries making code more readable and easy to understand.
---
 Reactor/ex1/src/main/java/utils/ReactorUtils.java | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/Reactor/ex1/src/main/java/utils/ReactorUtils.java b/Reactor/ex1/src/main/java/utils/ReactorUtils.java
index 1a516a98e..8e71d3965 100644
--- a/Reactor/ex1/src/main/java/utils/ReactorUtils.java
+++ b/Reactor/ex1/src/main/java/utils/ReactorUtils.java
@@ -95,7 +95,7 @@ public static <T> MonoSubject<T> makeHotMono(Mono<T> mono) {
      */
     public static <T> Flux<T> justConcurrentIf(T item, boolean parallel) {
         return Flux
-                // Just omit this one item.
+                // Just emit this one item.
                 .just(item)
 
                 // Conditionally convert to run concurrently.
@@ -112,7 +112,7 @@ public static <T> Flux<T> justConcurrentIf(T item, boolean parallel) {
      */
     public static <T extends Iterable<? extends T>> Flux<T> fromIterableConcurrentIf(T item, boolean parallel) {
         return Flux
-                // Just omit this one item.
+                // Just emit this one item.
                 .fromIterable(item)
 
                 // Conditionally convert to run concurrently.
@@ -127,7 +127,7 @@ public static <T extends Iterable<? extends T>> Flux<T> fromIterableConcurrentIf
      */
     public static <T> Mono<T> fromCallableConcurrent(Callable<T> item) {
           return Mono
-                  // Just omit this one item.
+                  // Just emit this one item.
                   .fromCallable(item)
 
                   // Conditionally convert to run concurrently.