Skip to content

Commit 9db06ab

Browse files
use appache commons classes in our Checked functional interfaces
1 parent 515c9b4 commit 9db06ab

File tree

6 files changed

+15
-15
lines changed

6 files changed

+15
-15
lines changed
Original file line numberDiff line numberDiff line change
@@ -1 +1 @@
1-
version=0.28.14
1+
version=0.28.15

airbyte-cdk/java/airbyte-cdk/dependencies/src/main/java/io/airbyte/commons/functional/CheckedBiConsumer.java

+3-3
Original file line numberDiff line numberDiff line change
@@ -4,9 +4,9 @@
44

55
package io.airbyte.commons.functional;
66

7-
@FunctionalInterface
8-
public interface CheckedBiConsumer<T, R, E extends Throwable> {
7+
import org.apache.commons.lang3.function.FailableBiConsumer;
98

10-
void accept(T t, R r) throws E;
9+
@FunctionalInterface
10+
public interface CheckedBiConsumer<T, R, E extends Throwable> extends FailableBiConsumer<T, R, E> {
1111

1212
}

airbyte-cdk/java/airbyte-cdk/dependencies/src/main/java/io/airbyte/commons/functional/CheckedBiFunction.java

+2-2
Original file line numberDiff line numberDiff line change
@@ -4,8 +4,8 @@
44

55
package io.airbyte.commons.functional;
66

7-
public interface CheckedBiFunction<First, Second, Result, E extends Throwable> {
7+
import org.apache.commons.lang3.function.FailableBiFunction;
88

9-
Result apply(First first, Second second) throws E;
9+
public interface CheckedBiFunction<First, Second, Result, E extends Throwable> extends FailableBiFunction<First, Second, Result, E> {
1010

1111
}

airbyte-cdk/java/airbyte-cdk/dependencies/src/main/java/io/airbyte/commons/functional/CheckedConsumer.java

+3-3
Original file line numberDiff line numberDiff line change
@@ -4,9 +4,9 @@
44

55
package io.airbyte.commons.functional;
66

7-
@FunctionalInterface
8-
public interface CheckedConsumer<T, E extends Throwable> {
7+
import org.apache.commons.lang3.function.FailableConsumer;
98

10-
void accept(T t) throws E;
9+
@FunctionalInterface
10+
public interface CheckedConsumer<T, E extends Throwable> extends FailableConsumer<T, E> {
1111

1212
}

airbyte-cdk/java/airbyte-cdk/dependencies/src/main/java/io/airbyte/commons/functional/CheckedFunction.java

+3-3
Original file line numberDiff line numberDiff line change
@@ -4,9 +4,9 @@
44

55
package io.airbyte.commons.functional;
66

7-
@FunctionalInterface
8-
public interface CheckedFunction<T, R, E extends Throwable> {
7+
import org.apache.commons.lang3.function.FailableFunction;
98

10-
R apply(T t) throws E;
9+
@FunctionalInterface
10+
public interface CheckedFunction<T, R, E extends Throwable> extends FailableFunction<T, R, E> {
1111

1212
}

airbyte-cdk/java/airbyte-cdk/dependencies/src/main/java/io/airbyte/commons/functional/CheckedSupplier.java

+3-3
Original file line numberDiff line numberDiff line change
@@ -4,9 +4,9 @@
44

55
package io.airbyte.commons.functional;
66

7-
@FunctionalInterface
8-
public interface CheckedSupplier<T, E extends Throwable> {
7+
import org.apache.commons.lang3.function.FailableSupplier;
98

10-
T get() throws E;
9+
@FunctionalInterface
10+
public interface CheckedSupplier<T, E extends Throwable> extends FailableSupplier<T, E> {
1111

1212
}

0 commit comments

Comments
 (0)