RequireNonNull in unchecked()

Author: Grzegorz Piwowarek

src/main/java/pl/touk/throwing/ThrowingBiConsumer.java

@@ -40,6 +40,8 @@ default ThrowingBiFunction<T, U, Void, E> asFunction() {
     }
 
     static <T, U, E extends Exception> BiConsumer<T, U> unchecked(ThrowingBiConsumer<T, U, E> consumer) {
+        Objects.requireNonNull(consumer);
+
         return consumer.unchecked();
     }
 

src/main/java/pl/touk/throwing/ThrowingBiFunction.java

@@ -33,6 +33,8 @@ default <V> ThrowingBiFunction<T1, T2, V, E> andThen(final ThrowingFunction<? su
     }
 
     static <T1, T2, R, E extends Exception> BiFunction<T1, T2, R> unchecked(ThrowingBiFunction<T1, T2, R, E> function) {
+        Objects.requireNonNull(function);
+
         return function.unchecked();
     }
 

src/main/java/pl/touk/throwing/ThrowingBiPredicate.java

@@ -46,6 +46,8 @@ default ThrowingBiFunction<T, U, Boolean, E> asFunction() {
     }
 
     static <T, U, E extends Exception> BiPredicate<T, U> unchecked(ThrowingBiPredicate<T, U, E> predicate) {
+        Objects.requireNonNull(predicate);
+
         return predicate.unchecked();
     }
 

src/main/java/pl/touk/throwing/ThrowingBinaryOperator.java

@@ -22,11 +22,13 @@ public interface ThrowingBinaryOperator<T, E extends Exception> extends Throwing
 
     static <T, E extends Exception> ThrowingBinaryOperator<T, E> minBy(Comparator<? super T> comparator) {
         Objects.requireNonNull(comparator);
+
         return (a, b) -> comparator.compare(a, b) <= 0 ? a : b;
     }
 
     static <T, E extends Exception> ThrowingBinaryOperator<T, E> maxBy(Comparator<? super T> comparator) {
         Objects.requireNonNull(comparator);
+
         return (a, b) -> comparator.compare(a, b) >= 0 ? a : b;
     }
 }

src/main/java/pl/touk/throwing/ThrowingConsumer.java

@@ -41,6 +41,8 @@ default ThrowingFunction<T, Void, E> asFunction() {
     }
 
     static <T, E extends Exception> Consumer<T> unchecked(ThrowingConsumer<T, E> consumer) {
+        Objects.requireNonNull(consumer);
+
         return consumer.unchecked();
     }
 

src/main/java/pl/touk/throwing/ThrowingFunction.java

@@ -35,6 +35,7 @@ default <V> ThrowingFunction<V, R, E> compose(final ThrowingFunction<? super V,
 
     default <V> ThrowingFunction<T, V, E> andThen(final ThrowingFunction<? super R, ? extends V, E> after) {
         Objects.requireNonNull(after);
+
         return (T t) -> after.apply(apply(t));
     }
 
@@ -53,6 +54,8 @@ default Function<T, Optional<R>> returningOptional() {
     }
 
     static <T, R, E extends Exception> Function<T, R> unchecked(ThrowingFunction<T, R, E> function) {
+        Objects.requireNonNull(function);
+
         return function.unchecked();
     }
 

src/main/java/pl/touk/throwing/ThrowingPredicate.java

@@ -56,6 +56,8 @@ default ThrowingFunction<T, Boolean, E> asFunction() {
     }
 
     static <T, E extends Exception> Predicate<T> unchecked(ThrowingPredicate<T, E> predicate) {
+        Objects.requireNonNull(predicate);
+
         return predicate.unchecked();
     }
 

src/main/java/pl/touk/throwing/ThrowingRunnable.java

@@ -1,5 +1,7 @@
 package pl.touk.throwing;
 
+import java.util.Objects;
+
 /**
  * Represents an action that can be performed.
  * Function might throw a checked exception instance.
@@ -11,6 +13,8 @@ public interface ThrowingRunnable<E extends Exception> {
     void run() throws E;
 
     static <E extends Exception> Runnable unchecked(ThrowingRunnable<E> runnable) {
+        Objects.requireNonNull(runnable);
+
         return runnable.unchecked();
     }
 

src/main/java/pl/touk/throwing/ThrowingSupplier.java

@@ -1,5 +1,6 @@
 package pl.touk.throwing;
 
+import java.util.Objects;
 import java.util.function.Supplier;
 
 /**
@@ -32,6 +33,8 @@ default ThrowingFunction<Void, T, E> asFunction() {
     }
 
     static <T, E extends Exception> Supplier<T> unchecked(ThrowingSupplier<T, E> supplier) {
+        Objects.requireNonNull(supplier);
+
         return supplier.unchecked();
     }
 

src/main/java/pl/touk/throwing/ThrowingUnaryOperator.java

@@ -1,5 +1,6 @@
 package pl.touk.throwing;
 
+import java.util.Objects;
 import java.util.function.UnaryOperator;
 
 /**
@@ -17,6 +18,8 @@
 public interface ThrowingUnaryOperator<T, E extends Exception> extends ThrowingFunction<T, T, E> {
 
     static <T, E extends Exception> UnaryOperator<T> unchecked(ThrowingUnaryOperator<T, E> operator) {
+        Objects.requireNonNull(operator);
+
         return operator.unchecked();
     }