Deprecated API

Contents

• Deprecated Classes
• Deprecated Methods
• Deprecated Constructors

Deprecated Classes

Class and Description
reactor.core.publisher.DirectProcessor To be removed in 3.5, prefer clear cut usage of Sinks. Closest sink is Sinks.many().multicast().directBestEffort(), except it doesn't terminate overflowing downstreams.
reactor.core.publisher.EmitterProcessor To be removed in 3.5. Prefer clear cut usage of Sinks through variations of Sinks.many().multicast().onBackpressureBuffer(). If you really need the subscribe-to-upstream functionality of a Processor, switch to Sinks.ManyWithUpstream with Sinks.unsafe() variants of Sinks.unsafe().manyWithUpstream(). This processor was blocking in EmitterProcessor.onNext(Object). This behaviour can be implemented with the Sinks API by calling Sinks.Many.tryEmitNext(Object) and retrying, e.g.: while (sink.tryEmitNext(v).hasFailed()) { LockSupport.parkNanos(10); }
reactor.core.publisher.FluxProcessor Processors will be removed in 3.5. Prefer using Sinks.Many instead, or see https://github.com/reactor/reactor-core/issues/2431 for alternatives
reactor.core.publisher.MonoProcessor Processors will be removed in 3.5. Prefer using Sinks.One or Sinks.Empty instead, or see https://github.com/reactor/reactor-core/issues/2431 for alternatives
reactor.core.publisher.ReplayProcessor To be removed in 3.5, prefer clear cut usage of Sinks through variations under Sinks.many().replay().
reactor.core.publisher.UnicastProcessor to be removed in 3.5, prefer clear cut usage of Sinks through variations under Sinks.many().unicast().

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.ReplayProcessor.cacheLast() use Sinks.many().replay().latest() (or the unsafe variant if you're sure about external synchronization). To be removed in 3.5.
reactor.core.publisher.ReplayProcessor.cacheLastOrDefault(T) use Sinks.many().replay().latestOrDefault(value) (or the unsafe variant if you're sure about external synchronization). To be removed in 3.5.
reactor.core.publisher.MonoProcessor.cancel() the MonoProcessor will cease to implement Subscription in 3.5
reactor.core.publisher.DirectProcessor.create() To be removed in 3.5. Closest sink is Sinks.many().multicast().directBestEffort(), except it doesn't terminate overflowing downstreams.
reactor.core.publisher.EmitterProcessor.create() use Sinks.many().multicast().onBackpressureBuffer() (or the unsafe variant if you're sure about external synchronization). To be removed in 3.5.
reactor.core.publisher.UnicastProcessor.create() use Sinks.many().unicast().onBackpressureBuffer() (or the unsafe variant if you're sure about external synchronization). To be removed in 3.5.
reactor.core.publisher.ReplayProcessor.create() use Sinks.many().replay().all() (or the unsafe variant if you're sure about external synchronization). To be removed in 3.5.
reactor.core.publisher.MonoProcessor.create() Use Sinks.one(), to be removed in 3.5
reactor.core.publisher.EmitterProcessor.create(boolean) use Sinks.many().multicast().onBackpressureBuffer(bufferSize, boolean) using the old default of Queues.SMALL_BUFFER_SIZE for the bufferSize (or the unsafe variant if you're sure about external synchronization). To be removed in 3.5.
reactor.core.publisher.EmitterProcessor.create(int) use Sinks.many().multicast().onBackpressureBuffer(bufferSize) (or the unsafe variant if you're sure about external synchronization). To be removed in 3.5.
reactor.core.publisher.ReplayProcessor.create(int) use Sinks.many().replay().limit(historySize) (or the unsafe variant if you're sure about external synchronization). To be removed in 3.5.
reactor.core.publisher.EmitterProcessor.create(int, boolean) use Sinks.many().multicast().onBackpressureBuffer(bufferSize, autoCancel) (or the unsafe variant if you're sure about external synchronization). To be removed in 3.5.
reactor.core.publisher.ReplayProcessor.create(int, boolean) use Sinks.many().replay().limit(historySize) for bounded cases (unbounded == false) or Sinks.many().replay().all(bufferSize) otherwise (or the unsafe variant if you're sure about external synchronization). To be removed in 3.5.
reactor.core.publisher.UnicastProcessor.create(Queue<E>) use Sinks.many().unicast().onBackpressureBuffer(queue) (or the unsafe variant if you're sure about external synchronization). To be removed in 3.5.
reactor.core.publisher.UnicastProcessor.create(Queue<E>, Consumer<? super E>, Disposable) use Sinks.many().unicast().onBackpressureBuffer(queue, endCallback) (or the unsafe variant if you're sure about external synchronization). The onOverflow callback is not supported anymore. To be removed in 3.5.
reactor.core.publisher.UnicastProcessor.create(Queue<E>, Disposable) use Sinks.many().unicast().onBackpressureBuffer(queue, endCallback) (or the unsafe variant if you're sure about external synchronization). To be removed in 3.5.
reactor.core.publisher.ReplayProcessor.createSizeAndTimeout(int, Duration) use Sinks.many().replay().limit(size, maxAge) (or the unsafe variant if you're sure about external synchronization). To be removed in 3.5.
reactor.core.publisher.ReplayProcessor.createSizeAndTimeout(int, Duration, Scheduler) use Sinks.many().replay().limit(size, maxAge, scheduler) (or the unsafe variant if you're sure about external synchronization). To be removed in 3.5.
reactor.core.publisher.ReplayProcessor.createTimeout(Duration) use Sinks.many().replay().limit(maxAge) (or the unsafe variant if you're sure about external synchronization). To be removed in 3.5.
reactor.core.publisher.ReplayProcessor.createTimeout(Duration, Scheduler) use Sinks.many().replay().limit(maxAge, scheduler) (or the unsafe variant if you're sure about external synchronization). To be removed in 3.5.
reactor.core.publisher.MonoSink.currentContext() To be removed in 3.6.0 at the earliest. Prefer using #getContextView() instead.
reactor.core.publisher.FluxSink.currentContext() To be removed in 3.6.0 at the earliest. Prefer using #getContextView() instead.
reactor.core.publisher.SynchronousSink.currentContext() To be removed in 3.6.0 at the earliest. Prefer using #getContextView() instead.
reactor.core.publisher.Mono.deferWithContext(Function<Context, ? extends Mono<? extends T>>) use Mono.deferContextual(Function) instead. to be removed in 3.5.0.
reactor.core.publisher.Flux.deferWithContext(Function<Context, ? extends Publisher<T>>) use Flux.deferContextual(Function)
reactor.core.publisher.Mono.doAfterSuccessOrError(BiConsumer<? super T, Throwable>) prefer using Mono.doAfterTerminate(Runnable) or Mono.doFinally(Consumer). will be removed in 3.5.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.5.0
reactor.core.scheduler.Schedulers.elastic() use Schedulers.boundedElastic(), to be removed in 3.5.0
reactor.core.publisher.Mono.first(Iterable<? extends Mono<? extends T>>) use Mono.firstWithSignal(Iterable). To be removed in reactor 3.5.
reactor.core.publisher.Flux.first(Iterable<? extends Publisher<? extends I>>) use Flux.firstWithSignal(Iterable). To be removed in reactor 3.5.
reactor.core.publisher.Mono.first(Mono<? extends T>...) use Mono.firstWithSignal(Mono[]). To be removed in reactor 3.5.
reactor.core.publisher.Flux.first(Publisher<? extends I>...) use Flux.firstWithSignal(Publisher[]). To be removed in reactor 3.5.
reactor.core.publisher.Signal.getContext() use Signal.getContextView() instead. To be removed in 3.5.0
reactor.core.publisher.MonoProcessor.isCancelled() the MonoProcessor will cease to implement Subscription and this method will be removed in 3.5
reactor.core.publisher.Flux.limitRequest(long) replace with take(n, true) in 3.4.x, then Flux.take(long) in 3.5.0. To be removed in 3.6.0 at the earliest. See https://github.com/reactor/reactor-core/issues/2339
reactor.core.publisher.Flux.mergeOrdered(Comparator<? super T>, Publisher<? extends T>...) Use Flux.mergeComparingDelayError(int, Comparator, Publisher[]) instead (as Flux.mergeComparing(Publisher[]) don't have this operator's delayError behavior). To be removed in 3.6.0 at the earliest.
reactor.core.publisher.Flux.mergeOrdered(int, Comparator<? super T>, Publisher<? extends T>...) Use Flux.mergeComparingDelayError(int, Comparator, Publisher[]) instead (as Flux.mergeComparing(Publisher[]) don't have this operator's delayError behavior). To be removed in 3.6.0 at the earliest.
reactor.core.publisher.Flux.mergeOrdered(Publisher<? extends I>...) Use Flux.mergeComparingDelayError(int, Comparator, Publisher[]) instead (as Flux.mergeComparing(Publisher[]) don't have this operator's delayError behavior). To be removed in 3.6.0 at the earliest.
reactor.core.publisher.Flux.mergeOrderedWith(Publisher<? extends T>, Comparator<? super T>) Use Flux.mergeComparingWith(Publisher, Comparator) instead (with the caveat that it defaults to NOT delaying errors, unlike this operator). To be removed in 3.6.0 at the earliest.
reactor.core.scheduler.Schedulers.newElastic(int, ThreadFactory) use Schedulers.newBoundedElastic(int, int, ThreadFactory, int), to be removed in 3.5.0
reactor.core.scheduler.Schedulers.Factory.newElastic(int, ThreadFactory) use Schedulers.Factory.newBoundedElastic(int, int, ThreadFactory, int), to be removed in 3.5.0
reactor.core.scheduler.Schedulers.newElastic(String) use Schedulers.newBoundedElastic(int, int, String), to be removed in 3.5.0
reactor.core.scheduler.Schedulers.newElastic(String, int) use Schedulers.newBoundedElastic(int, int, String, int), to be removed in 3.5.0
reactor.core.scheduler.Schedulers.newElastic(String, int, boolean) use Schedulers.newBoundedElastic(int, int, String, int, boolean), to be removed in 3.5.0
reactor.core.publisher.MonoProcessor.peek() this method is discouraged, consider peeking into a MonoProcessor by turning it into a CompletableFuture
reactor.core.publisher.Flux.publishNext() use Flux.shareNext() instead, or use `publish().next()` if you need to `connect(). To be removed in 3.5.0
reactor.util.context.Context.putAll(Context) will be removed in 3.5, kept for backward compatibility with 3.3. Until then if you need to work around the deprecation, use Context.putAll(ContextView) combined with Context.readOnly()
reactor.core.publisher.MonoProcessor.request(long) the MonoProcessor will cease to implement Subscription in 3.5
reactor.core.publisher.FluxProcessor.sink() To be removed in 3.5, prefer clear cut usage of Sinks through the Sinks.many() spec.
reactor.core.publisher.FluxProcessor.sink(FluxSink.OverflowStrategy) To be removed in 3.5, prefer clear cut usage of Sinks through the Sinks.many() spec.
reactor.core.scheduler.Scheduler.start() Use Scheduler.init() instead. The use of this method is discouraged. Some implementations allowed restarting a Scheduler, while others did not. One of the issues with restarting is that checking the disposed state is unreliable in concurrent scenarios.
reactor.core.publisher.Flux.subscribe(Consumer<? super T>, Consumer<? super Throwable>, Runnable, Consumer<? super Subscription>) Because users tend to forget to request the subsciption. If the behavior is really needed, consider using Flux.subscribeWith(Subscriber). To be removed in 3.5.
reactor.core.publisher.Mono.subscriberContext() Use Mono.deferContextual(Function) or Mono.transformDeferredContextual(BiFunction) to materialize the context. To obtain the same Mono of Context, use Mono.deferContextual(Mono::just). To be removed in 3.5.0.
reactor.core.publisher.Mono.subscriberContext(Context) Use Mono.contextWrite(ContextView) instead. To be removed in 3.5.0.
reactor.core.publisher.Flux.subscriberContext(Context) Use Flux.contextWrite(ContextView) instead. To be removed in 3.5.0.
reactor.core.publisher.Mono.subscriberContext(Function<Context, Context>) Use Mono.contextWrite(Function) instead. To be removed in 3.5.0.
reactor.core.publisher.Flux.subscriberContext(Function<Context, Context>) Use Flux.contextWrite(Function) instead. To be removed in 3.5.0.
reactor.core.publisher.Flux.switchMap(Function<? super T, Publisher<? extends V>>, int) to be removed in 3.6.0 at the earliest. In 3.5.0, you should replace calls with prefetch=0 with calls to switchMap(fn), as the default behavior of the single-parameter variant will then change to prefetch=0.
reactor.core.publisher.FluxProcessor.switchOnNext() should use Sinks, Sinks.Many.asFlux() and Flux.switchOnNext(Publisher). To be removed in 3.5.0.
reactor.core.publisher.Flux.switchOnNext(Publisher<? extends Publisher<? extends T>>, int) to be removed in 3.6.0 at the earliest. In 3.5.0, you should replace calls with prefetch=0 with calls to switchOnNext(mergedPublishers), as the default behavior of the single-parameter variant will then change to prefetch=0.
reactor.core.publisher.Mono.toProcessor() prefer Mono.share() to share a parent subscription, or use Sinks

Deprecated Constructors

Constructor and Description
reactor.core.publisher.UnicastProcessor(Queue<T>, Consumer<? super T>, Disposable)