diff --git a/spring-integration-kotlin-dsl/src/main/kotlin/org/springframework/integration/dsl/KotlinIntegrationFlowDefinition.kt b/spring-integration-kotlin-dsl/src/main/kotlin/org/springframework/integration/dsl/KotlinIntegrationFlowDefinition.kt index 239477f..6dca00d 100644 --- a/spring-integration-kotlin-dsl/src/main/kotlin/org/springframework/integration/dsl/KotlinIntegrationFlowDefinition.kt +++ b/spring-integration-kotlin-dsl/src/main/kotlin/org/springframework/integration/dsl/KotlinIntegrationFlowDefinition.kt @@ -111,16 +111,18 @@ class KotlinIntegrationFlowDefinition(private val adaptee: IntegrationFlowDefini * with reified generic type. */ inline fun convert( - crossinline configurer: (GenericEndpointSpec) -> Unit = {}): - KotlinIntegrationFlowDefinition = - convert(T::class.java) { configurer(it) } + crossinline configurer: (GenericEndpointSpec) -> Unit = {}) { + + convert(T::class.java) { configurer(it) } + } /** * Inline function for [IntegrationFlowDefinition.transform] providing a `transform()` variant * with reified generic type. */ - inline fun transform(crossinline function: (P) -> T): KotlinIntegrationFlowDefinition = - transform(P::class.java) { function(it) } + inline fun transform(crossinline function: (P) -> T) { + transform(P::class.java) { function(it) } + } /** * Inline function for [IntegrationFlowDefinition.transform] providing a `transform()` variant @@ -128,16 +130,19 @@ class KotlinIntegrationFlowDefinition(private val adaptee: IntegrationFlowDefini */ inline fun transform( crossinline function: (P) -> T, - crossinline configurer: (GenericEndpointSpec) -> Unit): - KotlinIntegrationFlowDefinition = - transform(P::class.java, { function(it) }) { configurer(it) } + crossinline configurer: (GenericEndpointSpec) -> Unit) { + + transform(P::class.java, { function(it) }) { configurer(it) } + } /** * Inline function for [IntegrationFlowDefinition.split] providing a `split()` variant * with reified generic type. */ - inline fun split(crossinline function: (P) -> Any): KotlinIntegrationFlowDefinition = - split(P::class.java) { function(it) } + inline fun split(crossinline function: (P) -> Any) { + split(P::class.java) { function(it) } + } + /** * Inline function for [IntegrationFlowDefinition.split] providing a `split()` variant @@ -145,17 +150,18 @@ class KotlinIntegrationFlowDefinition(private val adaptee: IntegrationFlowDefini */ inline fun split( crossinline function: (P) -> Any, - crossinline configurer: (SplitterEndpointSpec) -> Unit): - KotlinIntegrationFlowDefinition = - split(P::class.java, { function(it) }) { configurer(it) } + crossinline configurer: (SplitterEndpointSpec) -> Unit) { + + split(P::class.java, { function(it) }) { configurer(it) } + } /** * Inline function for [IntegrationFlowDefinition.filter] providing a `filter()` variant * with reified generic type. */ - inline fun filter(crossinline function: (P) -> Boolean): KotlinIntegrationFlowDefinition = - filter(P::class.java) { function(it) } - + inline fun filter(crossinline function: (P) -> Boolean) { + filter(P::class.java) { function(it) } + } /** * Inline function for [IntegrationFlowDefinition.filter] providing a `filter()` variant @@ -163,15 +169,19 @@ class KotlinIntegrationFlowDefinition(private val adaptee: IntegrationFlowDefini */ inline fun filter( crossinline function: (P) -> Boolean, - crossinline configurer: (FilterEndpointSpec) -> Unit): KotlinIntegrationFlowDefinition = - filter(P::class.java, { function(it) }) { configurer(it) } + crossinline configurer: (FilterEndpointSpec) -> Unit) { + + filter(P::class.java, { function(it) }) { configurer(it) } + } + /** * Inline function for [IntegrationFlowDefinition.filter] providing a `filter()` variant * with reified generic type. */ - inline fun route(crossinline function: (P) -> T): KotlinIntegrationFlowDefinition = - route(P::class.java) { function(it) } + inline fun route(crossinline function: (P) -> T) { + route(P::class.java) { function(it) } + } /** * Inline function for [IntegrationFlowDefinition.filter] providing a `filter()` variant @@ -179,8 +189,9 @@ class KotlinIntegrationFlowDefinition(private val adaptee: IntegrationFlowDefini */ inline fun route( crossinline function: (P) -> T, - crossinline configurer: (RouterSpec) -> Unit): - KotlinIntegrationFlowDefinition = - route(P::class.java, { function(it) }) { configurer(it) } + crossinline configurer: (RouterSpec) -> Unit) { + + route(P::class.java, { function(it) }) { configurer(it) } + } }