tagMetricsSubscriber

fun <T> Flux<T>.tagMetricsSubscriber(): Flux<T>