From 83fdc67e4a594d23cbfbfc287c4fa614a5c1d652 Mon Sep 17 00:00:00 2001
From: moparisthebest <admin@moparisthebest.com>
Date: Mon, 31 Aug 2020 21:48:55 -0400
Subject: [PATCH] Add AutoCloseableUtil.java for java8+

---
 .../jdbc/util/AutoCloseableUtil.java          | 47 +++++++++++++++++++
 pom.xml                                       |  1 +
 2 files changed, 48 insertions(+)
 create mode 100644 common/src/main/java/com/moparisthebest/jdbc/util/AutoCloseableUtil.java

diff --git a/common/src/main/java/com/moparisthebest/jdbc/util/AutoCloseableUtil.java b/common/src/main/java/com/moparisthebest/jdbc/util/AutoCloseableUtil.java
new file mode 100644
index 0000000..0ee86ce
--- /dev/null
+++ b/common/src/main/java/com/moparisthebest/jdbc/util/AutoCloseableUtil.java
@@ -0,0 +1,47 @@
+package com.moparisthebest.jdbc.util;
+
+import java.util.Iterator;
+import java.util.function.Consumer;
+import java.util.function.Function;
+import java.util.function.Supplier;
+import java.util.stream.Stream;
+
+public interface AutoCloseableUtil {
+
+    static <E extends AutoCloseable, T, R> R apply(final Supplier<E> supplier, final Function<? super E, R> action) {
+        try (final E stream = supplier.get()) {
+            return action.apply(stream);
+        } catch (Exception e) {
+            throw new RuntimeException(e);
+        }
+    }
+
+    static <E extends AutoCloseable, T> void accept(final Supplier<E> supplier, final Consumer<? super E> action) {
+        try (final E stream = supplier.get()) {
+            action.accept(stream);
+        } catch (Exception e) {
+            throw new RuntimeException(e);
+        }
+    }
+
+    static <E extends Stream<T>, T> void forEach(final Supplier<E> supplier, final Consumer<? super T> action) {
+        accept(supplier, s -> s.forEach(action));
+    }
+
+    static <E extends AutoCloseable & Iterable<T>, T> void forEachIt(final Supplier<E> supplier, final Consumer<? super T> action) {
+        accept(supplier, s -> {
+            for (final T val : s) {
+                action.accept(val);
+            }
+        });
+    }
+
+    static <T> void forEachRemove(final Iterator<T> iterator, final Function<? super T, Boolean> action) {
+        while (iterator.hasNext()) {
+            if (action.apply(iterator.next())) {
+                iterator.remove();
+            }
+        }
+    }
+
+}
diff --git a/pom.xml b/pom.xml
index 569497e..16128d7 100644
--- a/pom.xml
+++ b/pom.xml
@@ -246,6 +246,7 @@
                                 <excludes>
                                     <exclude>**/module-info.java</exclude>
                                     <exclude>**/PrestoPersonDAO.java</exclude>
+                                    <exclude>**/AutoCloseableUtil.java</exclude>
                                     <exclude>**/com/moparisthebest/jdbc/cache/*</exclude>
                                 </excludes>
                                 <compilerArgs>