log class name in FluxMapFuseable if mapper returns null

reactor · Mar 29, 2022 · 39ba753 · 39ba753
1 parent 4023191
commit 39ba753
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/reactor-core/src/main/java/reactor/core/publisher/FluxMap.java b/reactor-core/src/main/java/reactor/core/publisher/FluxMap.java
@@ -104,7 +104,7 @@ public void onNext(T t) {
 
 			try {
 				v = Objects.requireNonNull(mapper.apply(t),
-						"The mapper returned a null value.");
+						"The mapper [" + mapper.getClass().getName() + "] returned a null value.");
 			}
 			catch (Throwable e) {
 				Throwable e_ = Operators.onNextError(t, e, actual.currentContext(), s);

diff --git a/reactor-core/src/main/java/reactor/core/publisher/FluxMapFuseable.java b/reactor-core/src/main/java/reactor/core/publisher/FluxMapFuseable.java
@@ -111,7 +111,7 @@ public void onNext(T t) {
 
 				try {
 					v = Objects.requireNonNull(mapper.apply(t),
-							"The mapper returned a null value.");
+							"The mapper [" + mapper.getClass().getName() + "] returned a null value.");
 				}
 				catch (Throwable e) {
 					Throwable e_ = Operators.onNextError(t, e, actual.currentContext(), s);
@@ -279,7 +279,7 @@ public void onNext(T t) {
 
 				try {
 					v = Objects.requireNonNull(mapper.apply(t),
-							"The mapper returned a null value.");
+							"The mapper [" + mapper.getClass().getName() + "] returned a null value.");
 				}
 				catch (Throwable e) {
 					Throwable e_ = Operators.onNextError(t, e, actual.currentContext(), s);
@@ -307,7 +307,7 @@ public boolean tryOnNext(T t) {
 
 			try {
 				v = Objects.requireNonNull(mapper.apply(t),
-						"The mapper returned a null value.");
+						"The mapper [" + mapper.getClass().getName() + "] returned a null value.");
 				return actual.tryOnNext(v);
 			}
 			catch (Throwable e) {