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 MonoSubject makeHotMono(Mono mono) { */ public static Flux 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 Flux justConcurrentIf(T item, boolean parallel) { */ public static > Flux 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 > Flux fromIterableConcurrentIf */ public static Mono fromCallableConcurrent(Callable item) { return Mono - // Just omit this one item. + // Just emit this one item. .fromCallable(item) // Conditionally convert to run concurrently.