wow-opentelemetry/me.ahoo.wow.opentelemetry/TraceSubscriber

TraceSubscriber

open class TraceSubscriber<T : Any, O>(instrumenter: Instrumenter<T, Unit>, otelContext: Context, request: T, actual: CoreSubscriber<in O>) : CoreSubscriber<O>

Inheritors

ExchangeTraceSubscriber

Constructors

TraceSubscriber

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

Functions

currentContext

open override fun currentContext(): Context

onComplete

open override fun onComplete()

onError

open override fun onError(throwable: Throwable)

onNext

open override fun onNext(signal: O)

onSubscribe

open override fun onSubscribe(subscription: Subscription)