wow-opentelemetry/me.ahoo.wow.opentelemetry/ExchangeTraceSubscriber

ExchangeTraceSubscriber

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

Constructors

ExchangeTraceSubscriber

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

Functions

open override fun currentContext(): Context

open override fun onComplete()

open override fun onError(throwable: Throwable)

open override fun onNext(signal: Void)

open override fun onSubscribe(subscription: Subscription)