tagMetricsSubscriber

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

Tags a Flux stream with subscriber information from the reactive context. If no subscriber is present in the context, uses UNKNOWN_SUBSCRIBER so the tag schema stays stable.

Return

the tagged Flux stream

Type Parameters

T

the type of elements in the Flux


fun <T : Any> Flux<T>.tagMetricsSubscriber(defaultSubscriber: String): Flux<T>

Tags a Flux with a stable subscriber key. Reactor context can override the explicit fallback, while publishers without that context still use the same meter tag schema.