GH-STREAM 2704 Fix Consumer CCE on Kotlin Consumer

Resolves #2704
This commit is contained in:
Oleg Zhurakousky
2024-05-31 15:53:05 +02:00
parent 091d4eda41
commit 05416dbc30

View File

@@ -123,7 +123,11 @@ public class KotlinLambdaToFunctionAutoConfiguration {
if (this.kotlinLambdaTarget instanceof Function1) {
return ((Function1) this.kotlinLambdaTarget).invoke(arg0);
}
return ((Function) this.kotlinLambdaTarget).apply(arg0);
else if (this.kotlinLambdaTarget instanceof Function) {
return ((Function) this.kotlinLambdaTarget).apply(arg0);
}
((Consumer) this.kotlinLambdaTarget).accept(arg0);
return null;
}
@Override