Deprecated API

Contents

• Deprecated Classes
• Deprecated Methods

Deprecated Classes

Class and Description
reactor.util.concurrent.WaitStrategy Has been moved to io.projectreactor.addons:reactor-extra:3.3.0+ and will be removed in 3.4.0

Deprecated Methods

Method and Description
reactor.core.publisher.Hooks.addCallSiteInfo(P, String) Should only be used by the instrumentation, DOES NOT guarantee any compatibility
reactor.core.publisher.Hooks.addReturnInfo(P, String) Should only be used by the instrumentation, DOES NOT guarantee any compatibility
reactor.core.publisher.Flux.compose(Function<? super Flux<T>, ? extends Publisher<V>>) will be removed in 3.4.0, use Flux.transformDeferred(Function) instead
reactor.core.publisher.Mono.compose(Function<? super Mono<T>, ? extends Publisher<V>>) will be removed in 3.4.0, use Mono.transformDeferred(Function) instead
reactor.core.publisher.ParallelFlux.composeGroup(Function<? super GroupedFlux<Integer, T>, ? extends Publisher<? extends U>>) will be removed in 3.4.0. Use ParallelFlux.transformGroups(Function) instead
reactor.core.publisher.Mono.doAfterSuccessOrError(BiConsumer<? super T, Throwable>) prefer using Mono.doAfterTerminate(Runnable) or Mono.doFinally(Consumer). will be removed in 3.4.0
reactor.core.publisher.Mono.doOnSuccessOrError(BiConsumer<? super T, Throwable>) prefer using Mono.doOnNext(Consumer), Mono.doOnError(Consumer), Mono.doOnTerminate(Runnable) or Mono.doOnSuccess(Consumer). will be removed in 3.4.0
reactor.core.publisher.Flux.onLastAssembly(Flux<T>) use Operators.onLastAssembly(CorePublisher)
reactor.core.publisher.Mono.onLastAssembly(Mono<T>) use Operators.onLastAssembly(CorePublisher)
reactor.core.publisher.ParallelFlux.onLastAssembly(ParallelFlux<T>) use Operators.onLastAssembly(CorePublisher)
reactor.core.publisher.Flux.retry(long, Predicate<? super Throwable>) use Flux.retryWhen(Retry) instead, to be removed in 3.4
reactor.core.publisher.Mono.retry(long, Predicate<? super Throwable>) use Mono.retryWhen(Retry) instead, to be removed in 3.4
reactor.core.publisher.Flux.retry(Predicate<? super Throwable>) use Flux.retryWhen(Retry) instead, to be removed in 3.4
reactor.core.publisher.Mono.retry(Predicate<? super Throwable>) use Mono.retryWhen(Retry) instead, to be removed in 3.4
reactor.core.publisher.Flux.retryBackoff(long, Duration) use Flux.retryWhen(Retry) with a Retry.backoff(long, Duration) base, to be removed in 3.4
reactor.core.publisher.Mono.retryBackoff(long, Duration) use Mono.retryWhen(Retry) with a Retry.backoff(long, Duration) base, to be removed in 3.4
reactor.core.publisher.Flux.retryBackoff(long, Duration, Duration) use Flux.retryWhen(Retry) with a Retry.backoff(long, Duration) base, to be removed in 3.4
reactor.core.publisher.Mono.retryBackoff(long, Duration, Duration) use Mono.retryWhen(Retry) with a Retry.backoff(long, Duration) base, to be removed in 3.4
reactor.core.publisher.Flux.retryBackoff(long, Duration, Duration, double) use Flux.retryWhen(Retry) with a Retry.backoff(long, Duration) base
reactor.core.publisher.Mono.retryBackoff(long, Duration, Duration, double) use Mono.retryWhen(Retry) with a Retry.backoff(long, Duration) base, to be removed in 3.4
reactor.core.publisher.Flux.retryBackoff(long, Duration, Duration, double, Scheduler) use Flux.retryWhen(Retry) with a Retry.backoff(long, Duration) base
reactor.core.publisher.Mono.retryBackoff(long, Duration, Duration, double, Scheduler) use Mono.retryWhen(Retry) with a Retry.backoff(long, Duration) base, to be removed in 3.4
reactor.core.publisher.Flux.retryBackoff(long, Duration, Duration, Scheduler) use Flux.retryWhen(Retry) with a Retry.backoff(long, Duration) base, to be removed in 3.4
reactor.core.publisher.Mono.retryBackoff(long, Duration, Duration, Scheduler) use Mono.retryWhen(Retry) with a Retry.backoff(long, Duration) base, to be removed in 3.4
reactor.core.publisher.Flux.retryWhen(Function<Flux<Throwable>, ? extends Publisher<?>>) use Flux.retryWhen(Retry) instead, to be removed in 3.4. Lambda Functions that don't make use of the error can simply be converted by wrapping via Retry.from(Function). Functions that do use the error will additionally need to map the Retry.RetrySignal emitted by the companion to its Retry.RetrySignal#failure().
reactor.core.publisher.Mono.retryWhen(Function<Flux<Throwable>, ? extends Publisher<?>>) use Mono.retryWhen(Retry) instead, to be removed in 3.4. Lambda Functions that don't make use of the error can simply be converted by wrapping via Retry.from(Function). Functions that do use the error will additionally need to map the Retry.RetrySignal emitted by the companion to its Retry.RetrySignal#failure().
reactor.core.publisher.ParallelFlux.subscribe(Consumer<? super T>, Consumer<? super Throwable>, Runnable, Context)
reactor.core.publisher.Mono.usingWhen(Publisher<D>, Function<? super D, ? extends Mono<? extends T>>, Function<? super D, ? extends Publisher<?>>, Function<? super D, ? extends Publisher<?>>) prefer using the Mono.usingWhen(Publisher, Function, Function, BiFunction, Function) version which is more explicit about all termination cases, will be removed in 3.4.0
reactor.core.publisher.Mono.usingWhen(Publisher<D>, Function<? super D, ? extends Mono<? extends T>>, Function<? super D, ? extends Publisher<?>>, Function<? super D, ? extends Publisher<?>>, Function<? super D, ? extends Publisher<?>>) prefer using the Mono.usingWhen(Publisher, Function, Function, BiFunction, Function) version which is more explicit about all termination cases, will be removed in 3.4.0
reactor.core.publisher.Flux.usingWhen(Publisher<D>, Function<? super D, ? extends Publisher<? extends T>>, Function<? super D, ? extends Publisher<?>>, Function<? super D, ? extends Publisher<?>>) prefer using the Flux.usingWhen(Publisher, Function, Function, BiFunction, Function) version which is more explicit about all termination cases, will be removed in 3.4.0
reactor.core.publisher.Flux.usingWhen(Publisher<D>, Function<? super D, ? extends Publisher<? extends T>>, Function<? super D, ? extends Publisher<?>>, Function<? super D, ? extends Publisher<?>>, Function<? super D, ? extends Publisher<?>>) prefer using the Flux.usingWhen(Publisher, Function, Function, BiFunction, Function) version which is more explicit about all termination cases, will be removed in 3.4.0