Interface and Description |
---|
reactor.core.Cancellation
use
Disposable , will be removed in 3.1.0 |
Method and Description |
---|
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.then(Publisher<Void>)
use
Flux.thenEmpty(Publisher) instead, this alias will be
removed in 3.1.0 |