writeMetricsSubscriber

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

Writes the metrics subscriber identifier to the reactive context of a Flux stream.

Return

the Flux with updated context

Parameters

T

the type of elements in the Flux

metricsSubscriber

the subscriber identifier to write to context