add SuppressWarnings annotation

reactor · Feb 6, 2025 · 0994bb4 · 0994bb4
1 parent a3d3acc
commit 0994bb4
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/reactor-core/src/main/java/reactor/core/publisher/Mono.java b/reactor-core/src/main/java/reactor/core/publisher/Mono.java
@@ -5427,7 +5427,9 @@ static <T> Mono<T> wrap(Publisher<T> source, boolean enforceMonoContract) {
 		}
 
 		if (source instanceof Flux && source instanceof Callable) {
-			return Flux.wrapToMono((Callable<T>) source);
+			@SuppressWarnings("unchecked")
+			Callable<T> callable = (Callable<T>) source;
+			return Flux.wrapToMono(callable);
 		}
 
 		Mono<T> target = createMonoSource(source, enforceMonoContract);