onUnsubscribe

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

See also