Deprecated API

Contents

• Deprecated Interfaces
• Deprecated Fields
• Deprecated Methods

Deprecated Interfaces

Interface and Description
reactor.core.Cancellation use Disposable, will be removed in 3.1.0

Deprecated Fields

Field and Description
reactor.core.Exceptions.CANCEL_STACKTRACE Cancel stacktrace is always turned on given the exceptional frequency and the critical info it can provide

Deprecated Methods

Method and Description
reactor.core.publisher.Operators.addAndGet(AtomicLong, long) This util is neither used by Core nor consistent with the other `addAndGet` methods present which use AtomicLongFieldUpdater. In an effort to keep Operators API consistent, this util will not be supported anymore and users need to port over its body under their app code.
reactor.core.publisher.Flux.buffer(int, Duration) use Flux.bufferTimeout(int, Duration) instead, will be removed in 3.1.0
reactor.core.publisher.Flux.buffer(int, Duration, Supplier<C>) use Flux.bufferTimeout(int, Duration, Supplier) instead, will be removed in 3.1.0
reactor.core.publisher.Flux.bufferMillis(int, long) use Flux.bufferTimeoutMillis(int, long) instead, will be removed in 3.1.0
reactor.core.publisher.Flux.bufferMillis(int, long, TimedScheduler) use Flux.bufferTimeoutMillis(int, long, TimedScheduler) instead, will be removed in 3.1.0
reactor.core.publisher.Flux.bufferMillis(int, long, TimedScheduler, Supplier<C>) use Flux.bufferTimeoutMillis(int, long, TimedScheduler, Supplier) instead, will be removed in 3.1.0
reactor.core.publisher.Flux.delay(Duration) will be replaced by Flux.delayElements(Duration) in 3.1.0
reactor.core.publisher.Flux.delayMillis(long) will be replaced by Flux.delayElementsMillis(long) in 3.1.0
reactor.core.publisher.Flux.delayMillis(long, TimedScheduler) will be replaced by Flux.delayElementsMillis(long, TimedScheduler) in 3.1.0
reactor.core.publisher.ParallelFlux.isOrdered() This accessor was initially exposed to introspect the internal ordering scenario for parallel rails. In effect reactor 3.0 and 3.1 only offer non ordered merge at the end and therefore this should always returns false;
reactor.core.scheduler.Scheduler.shutdown() move the implementation to Scheduler.dispose() and call dispose from shutdown. Will be removed in 3.1.0
reactor.core.scheduler.Scheduler.Worker.shutdown() move the implementation to Scheduler.Worker.dispose() and call dispose from shutdown. Will be removed in 3.1.0
reactor.core.publisher.Flux.subscribe(Consumer<? super T>, Consumer<? super Throwable>, Runnable, Consumer<? super Subscription>, int) prefer using limitRate(prefetch).subscribe(...) to subscribe(..., prefetch)
reactor.core.publisher.Flux.subscribe(Consumer<? super T>, Consumer<? super Throwable>, Runnable, int) prefer using limitRate(prefetch).subscribe(...) to subscribe(..., prefetch)
reactor.core.publisher.Flux.subscribe(int) use Flux.limitRate(int)
reactor.core.publisher.Flux.then(Publisher<Void>) use Flux.thenEmpty(Publisher) instead, this alias will be removed in 3.1.0
reactor.util.concurrent.WaitStrategy.throwAlert() duplicate to WaitStrategy.alert()
reactor.core.publisher.Flux.window() will be removed in 3.1.0. Prefer using other variants, like Flux.window(Publisher),
reactor.core.publisher.Flux.window(int, Duration) use Flux.windowTimeout(int, Duration) instead, will be removed in 3.1.0
reactor.core.publisher.Flux.windowMillis(int, long) use Flux.windowTimeoutMillis(int, long) instead, will be removed in 3.1.0
reactor.core.publisher.Flux.windowMillis(int, long, TimedScheduler) use Flux.windowTimeoutMillis(int, long, TimedScheduler) instead, will be removed in 3.1.0
reactor.core.publisher.Flux.zip(Iterable<? extends Publisher<?>>) prefer using Flux.zip(Iterable, Function), will be removed in 3.1.0