✨ throwableFunction

Author: ccoderJava

summer-java-core/src/main/java/com/dianpoint/summer/lang/ThrowableConsumer.java

@@ -26,7 +26,7 @@ default void handleException(T t, Throwable throwable) {
      * @param t 入参
      */
     default void execute(T t) {
-
+        execute(t, this::handleException);
     }
 
     default void execute(T t, BiConsumer<T, Throwable> exceptionHandler) throws NullPointerException {
@@ -45,6 +45,6 @@ default void execute(T t, ThrowableConsumer<T> consumer) throws NullPointerExcep
     default void execute(T t, ThrowableConsumer<T> consumer, BiConsumer<T, Throwable> exceptionHandler)
             throws NullPointerException {
         AssertUtils.assertNotNull(exceptionHandler, () -> "The 'exceptionHandler' must not be null");
-        consumer.execute(t,exceptionHandler);
+        consumer.execute(t, exceptionHandler);
     }
 }

summer-java-core/src/main/java/com/dianpoint/summer/lang/ThrowableFunction.java

@@ -0,0 +1,50 @@
+package com.dianpoint.summer.lang;
+
+import com.dianpoint.summer.utils.AssertUtils;
+
+import java.util.function.BiFunction;
+
+/**
+ * 一个通用的抽象的处理异常的function
+ *
+ * @param <T> 入参
+ * @param <R> 结果
+ */
+@FunctionalInterface
+public interface ThrowableFunction<T, R> {
+
+    R apply(T t) throws Throwable;
+
+    default R handlerException(T t, Throwable throwable) {
+        throw new RuntimeException(throwable);
+    }
+
+    default R execute(T t, BiFunction<T, Throwable, R> exceptionHandler) {
+        R result;
+        try {
+            result = apply(t);
+        } catch (Throwable failure) {
+            result = exceptionHandler.apply(t, failure);
+        }
+        return result;
+    }
+
+    default R execute(T t) throws RuntimeException {
+        return execute(t, this::handlerException);
+    }
+
+    default <T, R> R execute(T t, ThrowableFunction<T, R> function, BiFunction<T, Throwable, R> exceptionHandler)
+            throws IllegalArgumentException {
+        AssertUtils.assertNotNull(function, "The 'function' must not be null");
+        AssertUtils.assertNotNull(exceptionHandler, "The 'exceptionHandler' must not be null");
+
+        return function.execute(t, exceptionHandler);
+    }
+
+    default <T, R> R execute(T t, ThrowableFunction<T, R> function) throws IllegalArgumentException {
+        AssertUtils.assertNotNull(function, "The 'function' must not be null");
+        return execute(t, function, function::handlerException);
+    }
+
+
+}