Companion

object Companion

Functions

Link copied to clipboard
fun <M> Flux<M>.tagSource(source: String): Flux<M>

Static extension function to tag a Flux publisher with a specified source identifier. This is used for metrics tagging to identify the component that generated the metrics.

fun <M> Mono<M>.tagSource(source: String): Mono<M>

Static extension function to tag a Mono publisher with a specified source identifier. This is used for metrics tagging to identify the component that generated the metrics.