use appache commons classes in our Checked functional interfaces

airbytehq · Mar 27, 2024 · 6d070ff · 6d070ff
1 parent 3bc8bed
commit 6d070ff
Show file tree

Hide file tree

Showing 6 changed files with 15 additions and 15 deletions.
diff --git a/airbyte-cdk/java/airbyte-cdk/core/src/main/resources/version.properties b/airbyte-cdk/java/airbyte-cdk/core/src/main/resources/version.properties
@@ -1 +1 @@
-version=0.28.14
+version=0.28.15
diff --git a/...rbyte-cdk/dependencies/src/main/java/io/airbyte/commons/functional/CheckedBiConsumer.java b/...rbyte-cdk/dependencies/src/main/java/io/airbyte/commons/functional/CheckedBiConsumer.java
@@ -4,9 +4,9 @@
 
 package io.airbyte.commons.functional;
 
-@FunctionalInterface
-public interface CheckedBiConsumer<T, R, E extends Throwable> {
+import org.apache.commons.lang3.function.FailableBiConsumer;
 
-  void accept(T t, R r) throws E;
+@FunctionalInterface
+public interface CheckedBiConsumer<T, R, E extends Throwable> extends FailableBiConsumer<T, R, E> {
 
 }
diff --git a/...rbyte-cdk/dependencies/src/main/java/io/airbyte/commons/functional/CheckedBiFunction.java b/...rbyte-cdk/dependencies/src/main/java/io/airbyte/commons/functional/CheckedBiFunction.java
@@ -4,8 +4,8 @@
 
 package io.airbyte.commons.functional;
 
-public interface CheckedBiFunction<First, Second, Result, E extends Throwable> {
+import org.apache.commons.lang3.function.FailableBiFunction;
 
-  Result apply(First first, Second second) throws E;
+public interface CheckedBiFunction<First, Second, Result, E extends Throwable> extends FailableBiFunction<First, Second, Result, E> {
 
 }
diff --git a/...airbyte-cdk/dependencies/src/main/java/io/airbyte/commons/functional/CheckedConsumer.java b/...airbyte-cdk/dependencies/src/main/java/io/airbyte/commons/functional/CheckedConsumer.java
@@ -4,9 +4,9 @@
 
 package io.airbyte.commons.functional;
 
-@FunctionalInterface
-public interface CheckedConsumer<T, E extends Throwable> {
+import org.apache.commons.lang3.function.FailableConsumer;
 
-  void accept(T t) throws E;
+@FunctionalInterface
+public interface CheckedConsumer<T, E extends Throwable> extends FailableConsumer<T, E> {
 
 }
diff --git a/...airbyte-cdk/dependencies/src/main/java/io/airbyte/commons/functional/CheckedFunction.java b/...airbyte-cdk/dependencies/src/main/java/io/airbyte/commons/functional/CheckedFunction.java
@@ -4,9 +4,9 @@
 
 package io.airbyte.commons.functional;
 
-@FunctionalInterface
-public interface CheckedFunction<T, R, E extends Throwable> {
+import org.apache.commons.lang3.function.FailableFunction;
 
-  R apply(T t) throws E;
+@FunctionalInterface
+public interface CheckedFunction<T, R, E extends Throwable> extends FailableFunction<T, R, E> {
 
 }
diff --git a/...airbyte-cdk/dependencies/src/main/java/io/airbyte/commons/functional/CheckedSupplier.java b/...airbyte-cdk/dependencies/src/main/java/io/airbyte/commons/functional/CheckedSupplier.java
@@ -4,9 +4,9 @@
 
 package io.airbyte.commons.functional;
 
-@FunctionalInterface
-public interface CheckedSupplier<T, E extends Throwable> {
+import org.apache.commons.lang3.function.FailableSupplier;
 
-  T get() throws E;
+@FunctionalInterface
+public interface CheckedSupplier<T, E extends Throwable> extends FailableSupplier<T, E> {
 
 }