wow-opentelemetry/me.ahoo.wow.opentelemetry/TraceMono

TraceMono

class TraceMono<T : Any, O : Any>(parentContext: Context, instrumenter: Instrumenter<T, Unit>, request: T, source: Mono<O>) : Mono<O>

Constructors

Link copied to clipboard
constructor(parentContext: Context, instrumenter: Instrumenter<T, Unit>, request: T, source: Mono<O>)

Functions

Link copied to clipboard
fun and(other: Publisher<*>): Mono<Void>
Link copied to clipboard
fun <P : Any> as(transformer: Function<in Mono<O>, P>): P
Link copied to clipboard
open fun block(): @Nullable O?
open fun block(timeout: Duration): @Nullable O?
Link copied to clipboard
open fun blockOptional(): Optional<O>
open fun blockOptional(timeout: Duration): Optional<O>
Link copied to clipboard
fun cache(): Mono<O>
fun cache(ttl: Duration): Mono<O>
fun cache(ttl: Duration, timer: Scheduler): Mono<O>
fun cache(ttlForValue: Function<in O, Duration>, ttlForError: Function<Throwable, Duration>, ttlForEmpty: Supplier<Duration>): Mono<O>
fun cache(ttlForValue: Function<in O, Duration>, ttlForError: Function<Throwable, Duration>, ttlForEmpty: Supplier<Duration>, timer: Scheduler): Mono<O>
Link copied to clipboard
fun cacheInvalidateIf(invalidationPredicate: Predicate<in O>): Mono<O>
Link copied to clipboard
fun cacheInvalidateWhen(invalidationTriggerGenerator: Function<in O, Mono<Void>>): Mono<O>
fun cacheInvalidateWhen(invalidationTriggerGenerator: Function<in O, Mono<Void>>, onInvalidate: Consumer<in O>): Mono<O>
Link copied to clipboard
fun cancelOn(scheduler: Scheduler): Mono<O>
Link copied to clipboard
fun <E : Any> cast(clazz: Class<E>): Mono<E>
Link copied to clipboard
fun checkpoint(): Mono<O>
fun checkpoint(description: String): Mono<O>
fun checkpoint(description: @Nullable String?, forceStackTrace: Boolean): Mono<O>
Link copied to clipboard
fun concatWith(other: Publisher<out O>): Flux<O>
Link copied to clipboard
fun contextCapture(): Mono<O>
Link copied to clipboard
fun contextWrite(contextModifier: Function<Context, Context>): Mono<O>
fun contextWrite(contextToAppend: ContextView): Mono<O>
Link copied to clipboard
fun defaultIfEmpty(defaultV: O): Mono<O>
Link copied to clipboard
fun delayElement(delay: Duration): Mono<O>
fun delayElement(delay: Duration, timer: Scheduler): Mono<O>
Link copied to clipboard
fun delaySubscription(delay: Duration): Mono<O>
fun <U : Any> delaySubscription(subscriptionDelay: Publisher<U>): Mono<O>
fun delaySubscription(delay: Duration, timer: Scheduler): Mono<O>
Link copied to clipboard
fun delayUntil(triggerProvider: Function<in O, out Publisher<*>>): Mono<O>
Link copied to clipboard
fun <X : Any> dematerialize(): Mono<X>
Link copied to clipboard
fun doAfterTerminate(afterTerminate: Runnable): Mono<O>
Link copied to clipboard
fun doFinally(onFinally: Consumer<SignalType>): Mono<O>
Link copied to clipboard
fun doFirst(onFirst: Runnable): Mono<O>
Link copied to clipboard
fun doOnCancel(onCancel: Runnable): Mono<O>
Link copied to clipboard
fun <R : Any> doOnDiscard(type: Class<R>, discardHook: Consumer<in R>): Mono<O>
Link copied to clipboard
fun doOnEach(signalConsumer: Consumer<in Signal<O>>): Mono<O>
Link copied to clipboard
fun doOnError(onError: Consumer<in Throwable>): Mono<O>
fun <E : Throwable> doOnError(exceptionType: Class<E>, onError: Consumer<in E>): Mono<O>
fun doOnError(predicate: Predicate<in Throwable>, onError: Consumer<in Throwable>): Mono<O>
Link copied to clipboard
fun doOnNext(onNext: Consumer<in O>): Mono<O>
Link copied to clipboard
fun doOnRequest(consumer: LongConsumer): Mono<O>
Link copied to clipboard
fun doOnSubscribe(onSubscribe: Consumer<in Subscription>): Mono<O>
Link copied to clipboard
fun doOnSuccess(onSuccess: Consumer<in @Nullable O?>): Mono<O>
Link copied to clipboard
fun doOnTerminate(onTerminate: Runnable): Mono<O>
Link copied to clipboard
fun elapsed(): Mono<Tuple2<Long, O>>
fun elapsed(scheduler: Scheduler): Mono<Tuple2<Long, O>>
Link copied to clipboard
fun expand(expander: Function<in O, out Publisher<out O>>): Flux<O>
fun expand(expander: Function<in O, out Publisher<out O>>, capacityHint: Int): Flux<O>
Link copied to clipboard
fun expandDeep(expander: Function<in O, out Publisher<out O>>): Flux<O>
fun expandDeep(expander: Function<in O, out Publisher<out O>>, capacityHint: Int): Flux<O>
Link copied to clipboard
fun filter(tester: Predicate<in O>): Mono<O>
Link copied to clipboard
fun filterWhen(asyncPredicate: Function<in O, out Publisher<Boolean>>): Mono<O>
Link copied to clipboard
fun <R : Any> flatMap(transformer: Function<in O, out Mono<out R>>): Mono<R>
Link copied to clipboard
fun <R : Any> flatMapIterable(mapper: Function<in O, out Iterable<out R>>): Flux<R>
Link copied to clipboard
fun <R : Any> flatMapMany(mapper: Function<in O, out Publisher<out R>>): Flux<R>
fun <R : Any> flatMapMany(mapperOnNext: Function<in O, out Publisher<out R>>, mapperOnError: Function<in Throwable, out Publisher<out R>>, mapperOnComplete: Supplier<out Publisher<out R>>): Flux<R>
Link copied to clipboard
fun flux(): Flux<O>
Link copied to clipboard
fun <R : Any> handle(handler: BiConsumer<in O, SynchronousSink<R>>): Mono<R>
Link copied to clipboard
fun hasElement(): Mono<Boolean>
Link copied to clipboard
fun hide(): Mono<O>
Link copied to clipboard
fun ignoreElement(): Mono<O>
Link copied to clipboard
fun log(): Mono<O>
fun log(category: @Nullable String?): Mono<O>
fun log(logger: Logger): Mono<O>
fun log(category: @Nullable String?, level: Level, vararg options: SignalType): Mono<O>
fun log(category: @Nullable String?, level: Level, showOperatorLine: Boolean, vararg options: SignalType): Mono<O>
fun log(logger: Logger, level: Level, showOperatorLine: Boolean, vararg options: SignalType): Mono<O>
Link copied to clipboard
fun <R : Any> map(mapper: Function<in O, out R>): Mono<R>
Link copied to clipboard
fun <R : Any> mapNotNull(mapper: Function<in O, out @Nullable R?>): Mono<R>
Link copied to clipboard
fun materialize(): Mono<Signal<O>>
Link copied to clipboard
fun mergeWith(other: Publisher<out O>): Flux<O>
Link copied to clipboard
fun metrics(): Mono<O>
Link copied to clipboard
fun name(name: String): Mono<O>
Link copied to clipboard
fun <U : Any> ofType(clazz: Class<U>): Mono<U>
Link copied to clipboard
fun onErrorComplete(): Mono<O>
fun onErrorComplete(type: Class<out Throwable>): Mono<O>
fun onErrorComplete(predicate: Predicate<in Throwable>): Mono<O>
Link copied to clipboard
fun onErrorContinue(errorConsumer: BiConsumer<Throwable, Any>): Mono<O>
fun <E : Throwable> onErrorContinue(type: Class<E>, errorConsumer: BiConsumer<Throwable, Any>): Mono<O>
fun <E : Throwable> onErrorContinue(errorPredicate: Predicate<E>, errorConsumer: BiConsumer<Throwable, Any>): Mono<O>
Link copied to clipboard
fun onErrorMap(mapper: Function<in Throwable, out Throwable>): Mono<O>
fun <E : Throwable> onErrorMap(type: Class<E>, mapper: Function<in E, out Throwable>): Mono<O>
fun onErrorMap(predicate: Predicate<in Throwable>, mapper: Function<in Throwable, out Throwable>): Mono<O>
Link copied to clipboard
fun onErrorResume(fallback: Function<in Throwable, out Mono<out O>>): Mono<O>
fun <E : Throwable> onErrorResume(type: Class<E>, fallback: Function<in E, out Mono<out O>>): Mono<O>
fun onErrorResume(predicate: Predicate<in Throwable>, fallback: Function<in Throwable, out Mono<out O>>): Mono<O>
Link copied to clipboard
fun onErrorReturn(fallbackValue: O): Mono<O>
fun <E : Throwable> onErrorReturn(type: Class<E>, fallbackValue: O): Mono<O>
fun onErrorReturn(predicate: Predicate<in Throwable>, fallbackValue: O): Mono<O>
Link copied to clipboard
fun onErrorStop(): Mono<O>
Link copied to clipboard
fun onTerminateDetach(): Mono<O>
Link copied to clipboard
fun or(other: Mono<out O>): Mono<O>
Link copied to clipboard
fun <R : Any> publish(transform: Function<in Mono<O>, out Mono<out R>>): Mono<R>
Link copied to clipboard
fun publishOn(scheduler: Scheduler): Mono<O>
Link copied to clipboard
fun repeat(): Flux<O>
fun repeat(predicate: BooleanSupplier): Flux<O>
fun repeat(numRepeat: Long): Flux<O>
fun repeat(numRepeat: Long, predicate: BooleanSupplier): Flux<O>
Link copied to clipboard
fun repeatWhen(repeatFactory: Function<Flux<Long>, out Publisher<*>>): Flux<O>
Link copied to clipboard
fun repeatWhenEmpty(repeatFactory: Function<Flux<Long>, out Publisher<*>>): Mono<O>
fun repeatWhenEmpty(maxRepeat: Int, repeatFactory: Function<Flux<Long>, out Publisher<*>>): Mono<O>
Link copied to clipboard
fun retry(): Mono<O>
fun retry(numRetries: Long): Mono<O>
Link copied to clipboard
fun retryWhen(retrySpec: Retry): Mono<O>
Link copied to clipboard
fun share(): Mono<O>
Link copied to clipboard
fun single(): Mono<O>
Link copied to clipboard
fun singleOptional(): Mono<Optional<O>>
Link copied to clipboard
open override fun subscribe(actual: CoreSubscriber<in O>)
fun subscribe(actual: Subscriber<in O>)
fun subscribe(): Disposable
fun subscribe(consumer: Consumer<in O>): Disposable
fun subscribe(consumer: @Nullable Consumer<in O>?, errorConsumer: Consumer<in Throwable>): Disposable
fun subscribe(consumer: @Nullable Consumer<in O>?, errorConsumer: @Nullable Consumer<in Throwable>?, completeConsumer: @Nullable Runnable?): Disposable
fun subscribe(consumer: @Nullable Consumer<in O>?, errorConsumer: @Nullable Consumer<in Throwable>?, completeConsumer: @Nullable Runnable?, subscriptionConsumer: @Nullable Consumer<in Subscription>?): Disposable
fun subscribe(consumer: @Nullable Consumer<in O>?, errorConsumer: @Nullable Consumer<in Throwable>?, completeConsumer: @Nullable Runnable?, initialContext: @Nullable Context?): Disposable
Link copied to clipboard
fun subscribeOn(scheduler: Scheduler): Mono<O>
Link copied to clipboard
fun <E : Subscriber<in O>> subscribeWith(subscriber: E): E
Link copied to clipboard
fun switchIfEmpty(alternate: Mono<out O>): Mono<O>
Link copied to clipboard
fun tag(key: String, value: String): Mono<O>
Link copied to clipboard
fun take(duration: Duration): Mono<O>
fun take(duration: Duration, timer: Scheduler): Mono<O>
Link copied to clipboard
fun takeUntilOther(other: Publisher<*>): Mono<O>
Link copied to clipboard
fun tap(listenerGenerator: Function<ContextView, SignalListener<O>>): Mono<O>
fun tap(simpleListenerGenerator: Supplier<SignalListener<O>>): Mono<O>
fun tap(listenerFactory: SignalListenerFactory<O, *>): Mono<O>
Link copied to clipboard
fun then(): Mono<Void>
fun <V : Any> then(other: Mono<V>): Mono<V>
Link copied to clipboard
fun thenEmpty(other: Publisher<Void>): Mono<Void>
Link copied to clipboard
fun <V : Any> thenMany(other: Publisher<V>): Flux<V>
Link copied to clipboard
fun <V : Any> thenReturn(value: V): Mono<V>
Link copied to clipboard
fun timed(): Mono<Timed<O>>
fun timed(clock: Scheduler): Mono<Timed<O>>
Link copied to clipboard
fun timeout(timeout: Duration): Mono<O>
fun <U : Any> timeout(firstTimeout: Publisher<U>): Mono<O>
fun timeout(timeout: Duration, fallback: Mono<out O>): Mono<O>
fun timeout(timeout: Duration, timer: Scheduler): Mono<O>
fun <U : Any> timeout(firstTimeout: Publisher<U>, fallback: Mono<out O>): Mono<O>
fun timeout(timeout: Duration, fallback: @Nullable Mono<out O>?, timer: Scheduler): Mono<O>
Link copied to clipboard
fun timestamp(): Mono<Tuple2<Long, O>>
fun timestamp(scheduler: Scheduler): Mono<Tuple2<Long, O>>
Link copied to clipboard
fun toFuture(): CompletableFuture<@Nullable O?>
Link copied to clipboard
fun <V : Any> transform(transformer: Function<in Mono<O>, out Publisher<V>>): Mono<V>
Link copied to clipboard
fun <V : Any> transformDeferred(transformer: Function<in Mono<O>, out Publisher<V>>): Mono<V>
Link copied to clipboard
fun <V : Any> transformDeferredContextual(transformer: BiFunction<in Mono<O>, in ContextView, out Publisher<V>>): Mono<V>
Link copied to clipboard
fun <T2 : Any> zipWhen(rightGenerator: Function<O, Mono<out T2>>): Mono<Tuple2<O, T2>>
fun <T2 : Any, O : Any> zipWhen(rightGenerator: Function<O, Mono<out T2>>, combinator: BiFunction<O, T2, O>): Mono<O>
Link copied to clipboard
fun <T2 : Any> zipWith(other: Mono<out T2>): Mono<Tuple2<O, T2>>
fun <T2 : Any, O : Any> zipWith(other: Mono<out T2>, combinator: BiFunction<in O, in T2, out O>): Mono<O>
Generated by Dokka
© 2026 Copyright