tagMetricsSubscriber

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

Tags a Flux stream with subscriber information from the reactive context. If no subscriber is present in the context, applies default metrics without subscriber tagging.

Return

the tagged Flux stream

Parameters

T

the type of elements in the Flux