spring-integration-core/org.springframework.integration.dsl/KotlinConsumerEndpointSpec/reactive

reactive

fun reactive()
fun reactive(reactiveCustomizer: (Flux<Message<*>>) -> Publisher<Message<*>>)