spring-integration-core/org.springframework.integration.dsl/KotlinIntegrationFlowDefinition/fluxTransform

fluxTransform

fun <I, O> fluxTransform(fluxFunction: (Flux<Message<I>>) -> Publisher<O>)

Populate a FluxMessageChannel to start a reactive processing for upstream data, wrap it to a Flux, apply provided function via Flux.transform and emit the result to one more FluxMessageChannel, subscribed in the downstream flow.