fun cache(ttlForValue: Function<in O?, Duration?>?, ttlForError: Function<Throwable?, Duration?>?, ttlForEmpty: Supplier<Duration?>?, timer: Scheduler?): Mono<O?>?

cacheInvalidateIf

fun cacheInvalidateIf(invalidationPredicate: Predicate<in O?>?): Mono<O?>?

cacheInvalidateWhen

fun cacheInvalidateWhen(invalidationTriggerGenerator: Function<in O?, Mono<Void?>?>?): Mono<O?>?

fun cacheInvalidateWhen(invalidationTriggerGenerator: Function<in O?, Mono<Void?>?>?, onInvalidate: Consumer<in O?>?): Mono<O?>?

cancelOn

fun cancelOn(scheduler: Scheduler?): Mono<O?>?

cast

fun <E : Any?> cast(clazz: Class<E?>?): Mono<E?>?

checkpoint

fun checkpoint(): Mono<O?>?

fun checkpoint(description: String?): Mono<O?>?

fun checkpoint(@Nullable description: String?, forceStackTrace: Boolean): Mono<O?>?

concatWith

fun concatWith(other: Publisher<out O?>?): Flux<O?>?

contextCapture

fun contextCapture(): Mono<O?>?

contextWrite

fun contextWrite(contextModifier: Function<Context?, Context?>?): Mono<O?>?

fun contextWrite(contextToAppend: ContextView?): Mono<O?>?

defaultIfEmpty

fun defaultIfEmpty(defaultV: O?): Mono<O?>?

delayElement

fun delayElement(delay: Duration?): Mono<O?>?

fun delayElement(delay: Duration?, timer: Scheduler?): Mono<O?>?

delaySubscription

fun delaySubscription(delay: Duration?): Mono<O?>?

fun delaySubscription(subscriptionDelay: Publisher<U?>?): Mono<O?>?

fun delaySubscription(delay: Duration?, timer: Scheduler?): Mono<O?>?

delayUntil

fun delayUntil(triggerProvider: Function<in O?, out Publisher<*>?>?): Mono<O?>?

dematerialize

fun <X : Any?> dematerialize(): Mono<X?>?

doAfterTerminate

fun doAfterTerminate(afterTerminate: Runnable?): Mono<O?>?

doFinally

fun doFinally(onFinally: Consumer<SignalType?>?): Mono<O?>?

doFirst

fun doFirst(onFirst: Runnable?): Mono<O?>?

doOnCancel

fun doOnCancel(onCancel: Runnable?): Mono<O?>?

doOnDiscard

fun <R : Any?> doOnDiscard(type: Class<R?>?, discardHook: Consumer<in R?>?): Mono<O?>?

doOnEach

fun doOnEach(signalConsumer: Consumer<in Signal<O?>?>?): Mono<O?>?

doOnError

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?>?

doOnNext

fun doOnNext(onNext: Consumer<in O?>?): Mono<O?>?

doOnRequest

fun doOnRequest(consumer: LongConsumer?): Mono<O?>?

doOnSubscribe

fun doOnSubscribe(onSubscribe: Consumer<in Subscription?>?): Mono<O?>?

doOnSuccess

fun doOnSuccess(onSuccess: Consumer<in O?>?): Mono<O?>?

doOnTerminate

fun doOnTerminate(onTerminate: Runnable?): Mono<O?>?

elapsed

fun elapsed(): Mono<Tuple2<Long?, O?>?>?

fun elapsed(scheduler: Scheduler?): Mono<Tuple2<Long?, O?>?>?

expand

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?>?

expandDeep

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?>?

filter

fun filter(tester: Predicate<in O?>?): Mono<O?>?

filterWhen

fun filterWhen(asyncPredicate: Function<in O?, out Publisher<Boolean?>?>?): Mono<O?>?

flatMap

fun <R : Any?> flatMap(transformer: Function<in O?, out Mono<out R?>?>?): Mono<R?>?

flatMapIterable

fun <R : Any?> flatMapIterable(mapper: Function<in O?, out Iterable<out R?>?>?): Flux<R?>?

flatMapMany

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?>?

flux

fun flux(): Flux<O?>?

handle

fun <R : Any?> handle(handler: BiConsumer<in O?, SynchronousSink<R?>?>?): Mono<R?>?

hasElement

fun hasElement(): Mono<Boolean?>?

hide

fun hide(): Mono<O?>?

ignoreElement

fun ignoreElement(): Mono<O?>?

log

fun log(): Mono<O?>?

fun log(@Nullable category: String?): Mono<O?>?

fun log(logger: Logger?): Mono<O?>?

fun log(@Nullable category: String?, level: Level?, vararg options: SignalType?): Mono<O?>?

fun log(@Nullable category: String?, level: Level?, showOperatorLine: Boolean, vararg options: SignalType?): Mono<O?>?

fun log(logger: Logger?, level: Level?, showOperatorLine: Boolean, vararg options: SignalType?): Mono<O?>?

map

fun <R : Any?> map(mapper: Function<in O?, out R?>?): Mono<R?>?

mapNotNull

fun <R : Any?> mapNotNull(mapper: Function<in O?, out R?>?): Mono<R?>?

materialize

fun materialize(): Mono<Signal<O?>?>?

mergeWith

fun mergeWith(other: Publisher<out O?>?): Flux<O?>?

metrics

fun ~~metrics~~(): Mono<O?>?

name

fun name(name: String?): Mono<O?>?

ofType

fun ofType(clazz: Class<U?>?): Mono<U?>?

onErrorComplete

fun onErrorComplete(): Mono<O?>?

fun onErrorComplete(type: Class<out Throwable?>?): Mono<O?>?

fun onErrorComplete(predicate: Predicate<in Throwable?>?): Mono<O?>?

onErrorContinue

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?>?

onErrorMap

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?>?

onErrorResume

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?>?

onErrorReturn

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?>?

onErrorStop

fun onErrorStop(): Mono<O?>?

onTerminateDetach

fun onTerminateDetach(): Mono<O?>?

fun or(other: Mono<out O?>?): Mono<O?>?

publish

fun <R : Any?> publish(transform: Function<in Mono<O?>?, out Mono<out R?>?>?): Mono<R?>?

publishOn

fun publishOn(scheduler: Scheduler?): Mono<O?>?

repeat

fun repeat(): Flux<O?>?

fun repeat(predicate: BooleanSupplier?): Flux<O?>?

fun repeat(numRepeat: Long): Flux<O?>?

fun repeat(numRepeat: Long, predicate: BooleanSupplier?): Flux<O?>?

repeatWhen

fun repeatWhen(repeatFactory: Function<Flux<Long?>?, out Publisher<*>?>?): Flux<O?>?

repeatWhenEmpty

fun repeatWhenEmpty(repeatFactory: Function<Flux<Long?>?, out Publisher<*>?>?): Mono<O?>?

fun repeatWhenEmpty(maxRepeat: Int, repeatFactory: Function<Flux<Long?>?, out Publisher<*>?>?): Mono<O?>?

retry

fun retry(): Mono<O?>?

fun retry(numRetries: Long): Mono<O?>?

retryWhen

fun retryWhen(retrySpec: Retry?): Mono<O?>?

fun share(): Mono<O?>?

single

fun single(): Mono<O?>?

singleOptional

fun singleOptional(): Mono<Optional<O?>?>?

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(@Nullable consumer: Consumer<in O?>?, errorConsumer: Consumer<in Throwable?>?): Disposable?

fun subscribe(@Nullable consumer: Consumer<in O?>?, @Nullable errorConsumer: Consumer<in Throwable?>?, @Nullable completeConsumer: Runnable?): Disposable?

fun subscribe(@Nullable consumer: Consumer<in O?>?, @Nullable errorConsumer: Consumer<in Throwable?>?, @Nullable completeConsumer: Runnable?, @Nullable subscriptionConsumer: Consumer<in Subscription?>?): Disposable?

fun subscribe(@Nullable consumer: Consumer<in O?>?, @Nullable errorConsumer: Consumer<in Throwable?>?, @Nullable completeConsumer: Runnable?, @Nullable initialContext: Context?): Disposable?

subscribeOn