refactor: add missing requireNonNull(exceptionType) of catching* …

…methods
foldright · Jul 28, 2024 · 7fb5d2b · 7fb5d2b
1 parent 5c12e98
commit 7fb5d2b
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/cffu-core/src/main/java/io/foldright/cffu/CompletableFutureUtils.java b/cffu-core/src/main/java/io/foldright/cffu/CompletableFutureUtils.java
@@ -3574,6 +3574,7 @@ public static CompletableFuture<Void> runAfterEitherSuccessAsync(
     public static <T, X extends Throwable, C extends CompletionStage<? super T>>
     C catching(C cfThis, Class<X> exceptionType, Function<? super X, ? extends T> fallback) {
         requireNonNull(cfThis, "cfThis is null");
+        requireNonNull(exceptionType, "exceptionType is null");
         requireNonNull(fallback, "fallback is null");
 
         return (C) cfThis.handle((v, ex) -> (ex == null || !exceptionType.isAssignableFrom(ex.getClass()))
@@ -3616,6 +3617,7 @@ C catchingAsync(C cfThis, Class<X> exceptionType, Function<? super X, ? extends
     public static <T, X extends Throwable, C extends CompletionStage<? super T>>
     C catchingAsync(C cfThis, Class<X> exceptionType, Function<? super X, ? extends T> fallback, Executor executor) {
         requireNonNull(cfThis, "cfThis is null");
+        requireNonNull(exceptionType, "exceptionType is null");
         requireNonNull(fallback, "fallback is null");
         requireNonNull(executor, "executor is null");
 
@@ -3872,7 +3874,9 @@ private static void completeCf(CompletableFuture<Object> cf, Object value, @Null
     public static <T, X extends Throwable, C extends CompletionStage<? super T>>
     C catchingCompose(C cfThis, Class<X> exceptionType, Function<? super X, ? extends CompletionStage<T>> fallback) {
         requireNonNull(cfThis, "cfThis is null");
+        requireNonNull(exceptionType, "exceptionType is null");
         requireNonNull(fallback, "fallback is null");
+
         return (C) cfThis.handle((v, ex) -> (ex == null || !exceptionType.isAssignableFrom(ex.getClass()))
                 ? cfThis : fallback.apply((X) ex)
         ).thenCompose(x -> x);
@@ -3913,8 +3917,10 @@ public static <T, X extends Throwable, C extends CompletionStage<? super T>> C c
             C cfThis, Class<X> exceptionType,
             Function<? super X, ? extends CompletionStage<T>> fallback, Executor executor) {
         requireNonNull(cfThis, "cfThis is null");
+        requireNonNull(exceptionType, "exceptionType is null");
         requireNonNull(fallback, "fallback is null");
         requireNonNull(executor, "executor is null");
+
         return (C) cfThis.handle((v, ex) -> (ex == null || !exceptionType.isAssignableFrom(ex.getClass()))
                 ? cfThis : cfThis.handleAsync((v1, ex1) -> fallback.apply((X) ex1), executor).thenCompose(x -> x)
         ).thenCompose(x -> x);