log class name in FluxMapSignal if mapper returns null

reactor · Mar 29, 2022 · a5510cc · a5510cc
1 parent 39ba753
commit a5510cc
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/reactor-core/src/main/java/reactor/core/publisher/FluxMapSignal.java b/reactor-core/src/main/java/reactor/core/publisher/FluxMapSignal.java
@@ -142,7 +142,7 @@ public void onNext(T t) {
 
             try {
                 v = Objects.requireNonNull(mapperNext.apply(t),
-		                "The mapper returned a null value.");
+		                "The mapper [" + mapperNext.getClass().getName() + "] returned a null value.");
             }
             catch (Throwable e) {
 	            done = true;
@@ -172,7 +172,7 @@ public void onError(Throwable t) {
 
 	        try {
 		        v = Objects.requireNonNull(mapperError.apply(t),
-				        "The mapper returned a null value.");
+				        "The mapper [" + mapperError.getClass().getName() + "] returned a null value.");
 	        }
 	        catch (Throwable e) {
 		        done = true;
@@ -204,7 +204,7 @@ public void onComplete() {
 
 	        try {
 		        v = Objects.requireNonNull(mapperComplete.get(),
-				        "The mapper returned a null value.");
+				        "The mapper [" + mapperComplete.getClass().getName() + "] returned a null value.");
 	        }
 	        catch (Throwable e) {
 		        done = true;