writeMetricsSubscriber

fun <T> Flux<T>.writeMetricsSubscriber(metricsSubscriber: String): Flux<T>