From e02aa127578b8f63dea3771d817ecc23853ec493 Mon Sep 17 00:00:00 2001 From: Stephane Geneix Date: Mon, 25 Mar 2024 08:09:44 -0700 Subject: [PATCH] convert functional interfaces to kotlin --- .../commons/functional/CheckedBiConsumer.java | 12 ------------ .../commons/functional/CheckedBiFunction.java | 11 ----------- .../airbyte/commons/functional/CheckedConsumer.java | 12 ------------ .../airbyte/commons/functional/CheckedFunction.java | 12 ------------ .../airbyte/commons/functional/CheckedSupplier.java | 12 ------------ .../airbyte/commons/functional/CheckedBiConsumer.kt | 9 +++++++++ .../airbyte/commons/functional/CheckedBiFunction.kt | 9 +++++++++ .../io/airbyte/commons/functional/CheckedConsumer.kt | 8 ++++++++ .../io/airbyte/commons/functional/CheckedFunction.kt | 8 ++++++++ .../io/airbyte/commons/functional/CheckedSupplier.kt | 8 ++++++++ 10 files changed, 42 insertions(+), 59 deletions(-) delete mode 100644 airbyte-cdk/java/airbyte-cdk/dependencies/src/main/java/io/airbyte/commons/functional/CheckedBiConsumer.java delete mode 100644 airbyte-cdk/java/airbyte-cdk/dependencies/src/main/java/io/airbyte/commons/functional/CheckedBiFunction.java delete mode 100644 airbyte-cdk/java/airbyte-cdk/dependencies/src/main/java/io/airbyte/commons/functional/CheckedConsumer.java delete mode 100644 airbyte-cdk/java/airbyte-cdk/dependencies/src/main/java/io/airbyte/commons/functional/CheckedFunction.java delete mode 100644 airbyte-cdk/java/airbyte-cdk/dependencies/src/main/java/io/airbyte/commons/functional/CheckedSupplier.java create mode 100644 airbyte-cdk/java/airbyte-cdk/dependencies/src/main/kotlin/io/airbyte/commons/functional/CheckedBiConsumer.kt create mode 100644 airbyte-cdk/java/airbyte-cdk/dependencies/src/main/kotlin/io/airbyte/commons/functional/CheckedBiFunction.kt create mode 100644 airbyte-cdk/java/airbyte-cdk/dependencies/src/main/kotlin/io/airbyte/commons/functional/CheckedConsumer.kt create mode 100644 airbyte-cdk/java/airbyte-cdk/dependencies/src/main/kotlin/io/airbyte/commons/functional/CheckedFunction.kt create mode 100644 airbyte-cdk/java/airbyte-cdk/dependencies/src/main/kotlin/io/airbyte/commons/functional/CheckedSupplier.kt diff --git a/airbyte-cdk/java/airbyte-cdk/dependencies/src/main/java/io/airbyte/commons/functional/CheckedBiConsumer.java b/airbyte-cdk/java/airbyte-cdk/dependencies/src/main/java/io/airbyte/commons/functional/CheckedBiConsumer.java deleted file mode 100644 index 7afd5b96152e4..0000000000000 --- a/airbyte-cdk/java/airbyte-cdk/dependencies/src/main/java/io/airbyte/commons/functional/CheckedBiConsumer.java +++ /dev/null @@ -1,12 +0,0 @@ -/* - * Copyright (c) 2023 Airbyte, Inc., all rights reserved. - */ - -package io.airbyte.commons.functional; - -import org.apache.commons.lang3.function.FailableBiConsumer; - -@FunctionalInterface -public interface CheckedBiConsumer extends FailableBiConsumer { - -} diff --git a/airbyte-cdk/java/airbyte-cdk/dependencies/src/main/java/io/airbyte/commons/functional/CheckedBiFunction.java b/airbyte-cdk/java/airbyte-cdk/dependencies/src/main/java/io/airbyte/commons/functional/CheckedBiFunction.java deleted file mode 100644 index c941435b0589e..0000000000000 --- a/airbyte-cdk/java/airbyte-cdk/dependencies/src/main/java/io/airbyte/commons/functional/CheckedBiFunction.java +++ /dev/null @@ -1,11 +0,0 @@ -/* - * Copyright (c) 2023 Airbyte, Inc., all rights reserved. - */ - -package io.airbyte.commons.functional; - -import org.apache.commons.lang3.function.FailableBiFunction; - -public interface CheckedBiFunction extends FailableBiFunction { - -} diff --git a/airbyte-cdk/java/airbyte-cdk/dependencies/src/main/java/io/airbyte/commons/functional/CheckedConsumer.java b/airbyte-cdk/java/airbyte-cdk/dependencies/src/main/java/io/airbyte/commons/functional/CheckedConsumer.java deleted file mode 100644 index 6905bd9e5d1d1..0000000000000 --- a/airbyte-cdk/java/airbyte-cdk/dependencies/src/main/java/io/airbyte/commons/functional/CheckedConsumer.java +++ /dev/null @@ -1,12 +0,0 @@ -/* - * Copyright (c) 2023 Airbyte, Inc., all rights reserved. - */ - -package io.airbyte.commons.functional; - -import org.apache.commons.lang3.function.FailableConsumer; - -@FunctionalInterface -public interface CheckedConsumer extends FailableConsumer { - -} diff --git a/airbyte-cdk/java/airbyte-cdk/dependencies/src/main/java/io/airbyte/commons/functional/CheckedFunction.java b/airbyte-cdk/java/airbyte-cdk/dependencies/src/main/java/io/airbyte/commons/functional/CheckedFunction.java deleted file mode 100644 index cf32b71e294b1..0000000000000 --- a/airbyte-cdk/java/airbyte-cdk/dependencies/src/main/java/io/airbyte/commons/functional/CheckedFunction.java +++ /dev/null @@ -1,12 +0,0 @@ -/* - * Copyright (c) 2023 Airbyte, Inc., all rights reserved. - */ - -package io.airbyte.commons.functional; - -import org.apache.commons.lang3.function.FailableFunction; - -@FunctionalInterface -public interface CheckedFunction extends FailableFunction { - -} diff --git a/airbyte-cdk/java/airbyte-cdk/dependencies/src/main/java/io/airbyte/commons/functional/CheckedSupplier.java b/airbyte-cdk/java/airbyte-cdk/dependencies/src/main/java/io/airbyte/commons/functional/CheckedSupplier.java deleted file mode 100644 index e15a9cf5b8fc7..0000000000000 --- a/airbyte-cdk/java/airbyte-cdk/dependencies/src/main/java/io/airbyte/commons/functional/CheckedSupplier.java +++ /dev/null @@ -1,12 +0,0 @@ -/* - * Copyright (c) 2023 Airbyte, Inc., all rights reserved. - */ - -package io.airbyte.commons.functional; - -import org.apache.commons.lang3.function.FailableSupplier; - -@FunctionalInterface -public interface CheckedSupplier extends FailableSupplier { - -} diff --git a/airbyte-cdk/java/airbyte-cdk/dependencies/src/main/kotlin/io/airbyte/commons/functional/CheckedBiConsumer.kt b/airbyte-cdk/java/airbyte-cdk/dependencies/src/main/kotlin/io/airbyte/commons/functional/CheckedBiConsumer.kt new file mode 100644 index 0000000000000..d6ec94cd8649d --- /dev/null +++ b/airbyte-cdk/java/airbyte-cdk/dependencies/src/main/kotlin/io/airbyte/commons/functional/CheckedBiConsumer.kt @@ -0,0 +1,9 @@ +/* + * Copyright (c) 2023 Airbyte, Inc., all rights reserved. + */ +package io.airbyte.commons.functional + +import org.apache.commons.lang3.function.FailableBiConsumer + +@FunctionalInterface +interface CheckedBiConsumer : FailableBiConsumer diff --git a/airbyte-cdk/java/airbyte-cdk/dependencies/src/main/kotlin/io/airbyte/commons/functional/CheckedBiFunction.kt b/airbyte-cdk/java/airbyte-cdk/dependencies/src/main/kotlin/io/airbyte/commons/functional/CheckedBiFunction.kt new file mode 100644 index 0000000000000..d6b36e27784b6 --- /dev/null +++ b/airbyte-cdk/java/airbyte-cdk/dependencies/src/main/kotlin/io/airbyte/commons/functional/CheckedBiFunction.kt @@ -0,0 +1,9 @@ +/* + * Copyright (c) 2023 Airbyte, Inc., all rights reserved. + */ +package io.airbyte.commons.functional + +import org.apache.commons.lang3.function.FailableBiFunction + +interface CheckedBiFunction : + FailableBiFunction diff --git a/airbyte-cdk/java/airbyte-cdk/dependencies/src/main/kotlin/io/airbyte/commons/functional/CheckedConsumer.kt b/airbyte-cdk/java/airbyte-cdk/dependencies/src/main/kotlin/io/airbyte/commons/functional/CheckedConsumer.kt new file mode 100644 index 0000000000000..c43e1d6f47737 --- /dev/null +++ b/airbyte-cdk/java/airbyte-cdk/dependencies/src/main/kotlin/io/airbyte/commons/functional/CheckedConsumer.kt @@ -0,0 +1,8 @@ +/* + * Copyright (c) 2023 Airbyte, Inc., all rights reserved. + */ +package io.airbyte.commons.functional + +import org.apache.commons.lang3.function.FailableConsumer + +@FunctionalInterface interface CheckedConsumer : FailableConsumer diff --git a/airbyte-cdk/java/airbyte-cdk/dependencies/src/main/kotlin/io/airbyte/commons/functional/CheckedFunction.kt b/airbyte-cdk/java/airbyte-cdk/dependencies/src/main/kotlin/io/airbyte/commons/functional/CheckedFunction.kt new file mode 100644 index 0000000000000..f26cbaa9ccd75 --- /dev/null +++ b/airbyte-cdk/java/airbyte-cdk/dependencies/src/main/kotlin/io/airbyte/commons/functional/CheckedFunction.kt @@ -0,0 +1,8 @@ +/* + * Copyright (c) 2023 Airbyte, Inc., all rights reserved. + */ +package io.airbyte.commons.functional + +import org.apache.commons.lang3.function.FailableFunction + +@FunctionalInterface interface CheckedFunction : FailableFunction diff --git a/airbyte-cdk/java/airbyte-cdk/dependencies/src/main/kotlin/io/airbyte/commons/functional/CheckedSupplier.kt b/airbyte-cdk/java/airbyte-cdk/dependencies/src/main/kotlin/io/airbyte/commons/functional/CheckedSupplier.kt new file mode 100644 index 0000000000000..26c1776f8a6b9 --- /dev/null +++ b/airbyte-cdk/java/airbyte-cdk/dependencies/src/main/kotlin/io/airbyte/commons/functional/CheckedSupplier.kt @@ -0,0 +1,8 @@ +/* + * Copyright (c) 2023 Airbyte, Inc., all rights reserved. + */ +package io.airbyte.commons.functional + +import org.apache.commons.lang3.function.FailableSupplier + +@FunctionalInterface interface CheckedSupplier : FailableSupplier