Method and Description |
---|
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 |