datasourcex-java-flow/com.caplin.integration.datasourcex.reactive.java/Bind/active

active

fun active(active: Consumer<BindActive>)(source)
fun active(active: BindActive.() -> Unit)(source)

Configure bindings for Active (AKA Cold) publishers.

This should be used for demand driven publication. Publication will be started when first requested and cancelled when no longer needed.