onSubscribe

fun onSubscribe(block: suspend PipelineContext<S, I, A>.(newSubscriberCount: Int) -> Unit)

See also