ExchangeTraceSubscriber

class ExchangeTraceSubscriber<T : MessageExchange<*, *>>(instrumenter: Instrumenter<T, Unit>, otelContext: Context, exchange: T, actual: CoreSubscriber<in Void>) : TraceSubscriber<T, Void>

Constructors

constructor(instrumenter: Instrumenter<T, Unit>, otelContext: Context, exchange: T, actual: CoreSubscriber<in Void>)

open override fun onComplete()