Deprecated List (Reactor Core 3.1.0.M2)

Deprecated Methods
Method and Description
reactor.core.publisher.WorkQueueProcessor.create(boolean) use the Builder (`WorkQueueProcessor.builder()` and its `build()` method)
reactor.core.publisher.EmitterProcessor.create(boolean) use the Builder (`EmitterProcessor.builder()` and its `EmitterProcessor.Builder.build()` method)
reactor.core.publisher.TopicProcessor.create(boolean) use the Builder (`TopicProcessor.builder()` and its `TopicProcessor.Builder.build()` method)
reactor.core.publisher.WorkQueueProcessor.create(ExecutorService) use the Builder (`WorkQueueProcessor.builder()` and its `build()` method)
reactor.core.publisher.TopicProcessor.create(ExecutorService) use the Builder (`TopicProcessor.builder()` and its `TopicProcessor.Builder.build()` method)
reactor.core.publisher.WorkQueueProcessor.create(ExecutorService, boolean) use the Builder (`WorkQueueProcessor.builder()` and its `build()` method)
reactor.core.publisher.TopicProcessor.create(ExecutorService, boolean) use the Builder (`TopicProcessor.builder()` and its `TopicProcessor.Builder.build()` method)
reactor.core.publisher.WorkQueueProcessor.create(ExecutorService, ExecutorService, int, WaitStrategy, boolean) use the Builder (`WorkQueueProcessor.builder()` and its `build()` method)
reactor.core.publisher.TopicProcessor.create(ExecutorService, ExecutorService, int, WaitStrategy, boolean) use the Builder (`TopicProcessor.builder()` and its `TopicProcessor.Builder.build()` method)
reactor.core.publisher.WorkQueueProcessor.create(ExecutorService, int) use the Builder (`WorkQueueProcessor.builder()` and its `build()` method)
reactor.core.publisher.TopicProcessor.create(ExecutorService, int) use the Builder (`TopicProcessor.builder()` and its `TopicProcessor.Builder.build()` method)
reactor.core.publisher.WorkQueueProcessor.create(ExecutorService, int, boolean) use the Builder (`WorkQueueProcessor.builder()` and its `build()` method)
reactor.core.publisher.TopicProcessor.create(ExecutorService, int, boolean) use the Builder (`TopicProcessor.builder()` and its `TopicProcessor.Builder.build()` method)
reactor.core.publisher.WorkQueueProcessor.create(ExecutorService, int, WaitStrategy) use the Builder (`WorkQueueProcessor.builder()` and its `build()` method)
reactor.core.publisher.TopicProcessor.create(ExecutorService, int, WaitStrategy) use the Builder (`TopicProcessor.builder()` and its `TopicProcessor.Builder.build()` method)
reactor.core.publisher.WorkQueueProcessor.create(ExecutorService, int, WaitStrategy, boolean) use the Builder (`WorkQueueProcessor.builder()` and its `build()` method)
reactor.core.publisher.TopicProcessor.create(ExecutorService, int, WaitStrategy, boolean) use the Builder (`TopicProcessor.builder()` and its `TopicProcessor.Builder.build()` method)
reactor.core.publisher.EmitterProcessor.create(int) use the Builder (`EmitterProcessor.builder()` and its `EmitterProcessor.Builder.build()` method)
reactor.core.publisher.EmitterProcessor.create(int, boolean) use the Builder (`EmitterProcessor.builder()` and its `EmitterProcessor.Builder.build()` method)
reactor.core.publisher.UnicastProcessor.create(Queue<E>) use the Builder (`UnicastProcessor.builder()` and its `UnicastProcessor.Builder.build()` method)
reactor.core.publisher.UnicastProcessor.create(Queue<E>, Consumer<? super E>, Disposable) use `UnicastProcessor.Builder.build()`
reactor.core.publisher.UnicastProcessor.create(Queue<E>, Disposable) use `UnicastProcessor.Builder.build()`
reactor.core.publisher.WorkQueueProcessor.create(String) use the Builder (`WorkQueueProcessor.builder()` and its `build()` method)
reactor.core.publisher.TopicProcessor.create(String) use the Builder (`TopicProcessor.builder()` and its `TopicProcessor.Builder.build()` method)
reactor.core.publisher.WorkQueueProcessor.create(String, int) use the Builder (`WorkQueueProcessor.builder()` and its `build()` method)
reactor.core.publisher.TopicProcessor.create(String, int) use the Builder (`TopicProcessor.builder()` and its `TopicProcessor.Builder.build()` method)
reactor.core.publisher.WorkQueueProcessor.create(String, int, boolean) use the Builder (`WorkQueueProcessor.builder()` and its `build()` method)
reactor.core.publisher.TopicProcessor.create(String, int, boolean) use the Builder (`TopicProcessor.builder()` and its `TopicProcessor.Builder.build()` method)
reactor.core.publisher.WorkQueueProcessor.create(String, int, WaitStrategy) use the Builder (`WorkQueueProcessor.builder()` and its `build()` method)
reactor.core.publisher.TopicProcessor.create(String, int, WaitStrategy) use the Builder (`TopicProcessor.builder()` and its `TopicProcessor.Builder.build()` method)
reactor.core.publisher.WorkQueueProcessor.create(String, int, WaitStrategy, boolean) use the Builder (`WorkQueueProcessor.builder()` and its `build()` method)
reactor.core.publisher.TopicProcessor.create(String, int, WaitStrategy, boolean) use the Builder (`TopicProcessor.builder()` and its `TopicProcessor.Builder.build()` method)
reactor.core.publisher.TopicProcessor.create(String, int, WaitStrategy, Supplier<E>) use the Builder (`TopicProcessor.builder()` and its `TopicProcessor.Builder.build()` method)
reactor.core.publisher.WorkQueueProcessor.share(boolean) use the Builder (`WorkQueueProcessor.builder()` and its `build()` method)
reactor.core.publisher.TopicProcessor.share(boolean) use the Builder (`TopicProcessor.builder()` and its `TopicProcessor.Builder.build()` method)
reactor.core.publisher.WorkQueueProcessor.share(ExecutorService) use the Builder (`WorkQueueProcessor.builder()` and its `build()` method)
reactor.core.publisher.TopicProcessor.share(ExecutorService) use the Builder (`TopicProcessor.builder()` and its `TopicProcessor.Builder.build()` method)
reactor.core.publisher.WorkQueueProcessor.share(ExecutorService, boolean) use the Builder (`WorkQueueProcessor.builder()` and its `build()` method)
reactor.core.publisher.TopicProcessor.share(ExecutorService, boolean) use the Builder (`TopicProcessor.builder()` and its `TopicProcessor.Builder.build()` method)
reactor.core.publisher.WorkQueueProcessor.share(ExecutorService, ExecutorService, int, WaitStrategy, boolean) use the Builder (`WorkQueueProcessor.builder()` and its `build()` method)
reactor.core.publisher.TopicProcessor.share(ExecutorService, ExecutorService, int, WaitStrategy, boolean) use the Builder (`TopicProcessor.builder()` and its `TopicProcessor.Builder.build()` method)
reactor.core.publisher.WorkQueueProcessor.share(ExecutorService, int) use the Builder (`WorkQueueProcessor.builder()` and its `build()` method)
reactor.core.publisher.TopicProcessor.share(ExecutorService, int) use the Builder (`TopicProcessor.builder()` and its `TopicProcessor.Builder.build()` method)
reactor.core.publisher.WorkQueueProcessor.share(ExecutorService, int, boolean) use the Builder (`WorkQueueProcessor.builder()` and its `build()` method)
reactor.core.publisher.TopicProcessor.share(ExecutorService, int, boolean) use the Builder (`TopicProcessor.builder()` and its `TopicProcessor.Builder.build()` method)
reactor.core.publisher.WorkQueueProcessor.share(ExecutorService, int, WaitStrategy) use the Builder (`WorkQueueProcessor.builder()` and its `build()` method)
reactor.core.publisher.TopicProcessor.share(ExecutorService, int, WaitStrategy) use the Builder (`TopicProcessor.builder()` and its `TopicProcessor.Builder.build()` method)
reactor.core.publisher.WorkQueueProcessor.share(ExecutorService, int, WaitStrategy, boolean) use the Builder (`WorkQueueProcessor.builder()` and its `build()` method)
reactor.core.publisher.TopicProcessor.share(ExecutorService, int, WaitStrategy, boolean) use the Builder (`TopicProcessor.builder()` and its `TopicProcessor.Builder.build()` method)
reactor.core.publisher.WorkQueueProcessor.share(String, int) use the Builder (`WorkQueueProcessor.builder()` and its `build()` method)
reactor.core.publisher.TopicProcessor.share(String, int) use the Builder (`TopicProcessor.builder()` and its `TopicProcessor.Builder.build()` method)
reactor.core.publisher.WorkQueueProcessor.share(String, int, boolean) use the Builder (`WorkQueueProcessor.builder()` and its `build()` method)
reactor.core.publisher.TopicProcessor.share(String, int, boolean) use the Builder (`TopicProcessor.builder()` and its `TopicProcessor.Builder.build()` method)
reactor.core.publisher.TopicProcessor.share(String, int, Supplier<E>) use the Builder (`TopicProcessor.builder()` and its `TopicProcessor.Builder.build()` method)
reactor.core.publisher.WorkQueueProcessor.share(String, int, WaitStrategy) use the Builder (`WorkQueueProcessor.builder()` and its `build()` method)
reactor.core.publisher.TopicProcessor.share(String, int, WaitStrategy) use the Builder (`TopicProcessor.builder()` and its `TopicProcessor.Builder.build()` method)
reactor.core.publisher.WorkQueueProcessor.share(String, int, WaitStrategy, boolean) use the Builder (`WorkQueueProcessor.builder()` and its `build()` method)
reactor.core.publisher.TopicProcessor.share(String, int, WaitStrategy, boolean) use the Builder (`TopicProcessor.builder()` and its `TopicProcessor.Builder.build()` method)
reactor.core.publisher.TopicProcessor.share(String, int, WaitStrategy, Supplier<E>) use the Builder (`TopicProcessor.builder()` and its `TopicProcessor.Builder.build()` method)
reactor.core.publisher.Mono.untilOther(Publisher<?>) This will be removed in 3.1.0, use `Mono.delayUntilOther(Publisher)` instead, associated with `take(1)` for `Flux` if you really want the onNext triggers" behavior.
reactor.core.publisher.Mono.untilOtherDelayError(Publisher<?>) This will be removed in 3.1.0, use `Mono.delayUntilOther(Publisher)` instead, associated with `take(1)` for `Flux` if you really want the onNext triggers" behavior.
reactor.core.publisher.Mono.zip(Function<? super Object[], ? extends V>, Iterable<? extends Mono<? extends T>>) will be removed in 3.1.0.RELEASE at most. Swapt the arguments to us `Mono.zip(Iterable, Function)`)} instead.

Deprecated API

Contents