Upgrading io.projectreactor:reactor-core 2 to 3

Unknown2.0.8.RELEASE → 3.8.8Deprecated2New70Changed22Fixed10Other15

Full comparison Back to io.projectreactor:reactor-core

Fetching 195 releases from GitHub…36 / 195

UnknownUpgrade verdict

DepDelta is still reading the notes for 159 of 195 releases, so breaking changes can't be ruled out yet.

In plain terms

DepDelta is still reading the release notes in this range, so it can't rule out breaking changes yet.
This page updates as the notes come in.

Must act 2 items need code or config changes

Adds org.jspecify:jspecify 1.0.1.

Drops org.slf4j:slf4j-api.

Deprecations to plan for

Deprecated2

Introduce JSpecify for nullability annotations.

3.8.0GitHub ReleaseOriginalView source

Introduce JSpecify for nullability annotations.

3.8.0-RC1GitHub ReleaseOriginalView source

API changes

Generated by DepDelta from published JVM bytecode. Not mixed with prose notes.

removed: class Environment implements Iterable, Closeable
removed: ctor Environment()
removed: ctor Environment(ConfigurationReader)
removed: ctor Environment(Map, ConfigurationReader)
removed: method Environment.addCachedDispatchers(String, DispatcherSupplier): Environment
removed: method Environment.assignErrorJournal(): Environment
removed: method Environment.assignErrorJournal(Consumer): Environment
removed: method Environment.close(): void
removed: method Environment.getCachedDispatcher(): Dispatcher
removed: method Environment.getCachedDispatchers(): DispatcherSupplier
removed: method Environment.getCachedDispatchers(String): DispatcherSupplier
removed: method Environment.getDefaultDispatcher(): Dispatcher
removed: method Environment.getDispatcher(String): Dispatcher
removed: method Environment.getIntProperty(String, int): int
removed: method Environment.getLongProperty(String, long): long
removed: method Environment.getProperty(String, String): String
removed: method Environment.getTimer(): Timer
removed: method Environment.iterator(): Iterator
removed: method Environment.removeCachedDispatchers(String): Environment
removed: method Environment.removeDispatcher(String): Environment
removed: method Environment.routeError(Throwable): void
removed: method Environment.setDispatcher(String, Dispatcher): Environment
removed: method Environment.shutdown(): void
removed: static field Environment.DISPATCHER_GROUP: String
removed: static field Environment.MPSC: String
removed: static field Environment.PROCESSORS: int
removed: static field Environment.SHARED: String
removed: static field Environment.THREAD_POOL: String
removed: static field Environment.WORK_QUEUE: String
removed: static method Environment.alive(): boolean
removed: static method Environment.assign(Environment): Environment
removed: static method Environment.cachedDispatcher(): Dispatcher
removed: static method Environment.cachedDispatchers(): DispatcherSupplier
removed: static method Environment.cachedDispatchers(String): DispatcherSupplier
removed: static method Environment.cachedDispatchers(String, DispatcherSupplier): DispatcherSupplier
removed: static method Environment.createDispatcherFactory(String, int, int, Consumer, ProducerType, WaitStrategy): DispatcherSupplier
removed: static method Environment.dispatcher(String): Dispatcher
removed: static method Environment.dispatcher(String, Dispatcher): Dispatcher
removed: static method Environment.get(): Environment
removed: static method Environment.initialize(): Environment
removed: static method Environment.initialize(Consumer): Environment
removed: static method Environment.initializeIfEmpty(): Environment
removed: static method Environment.newCachedDispatchers(int): DispatcherSupplier
removed: static method Environment.newCachedDispatchers(int, String): DispatcherSupplier
removed: static method Environment.newDispatcher(): Dispatcher
removed: static method Environment.newDispatcher(String, int): Dispatcher
removed: static method Environment.newDispatcher(String, int, int): Dispatcher
removed: static method Environment.newDispatcher(String, int, int, DispatcherType): Dispatcher
removed: static method Environment.newDispatcher(int): Dispatcher
removed: static method Environment.newDispatcher(int, int): Dispatcher
removed: static method Environment.newDispatcher(int, int, DispatcherType): Dispatcher
removed: static method Environment.newDispatcherLike(String): Dispatcher
removed: static method Environment.newDispatcherLike(String, String): Dispatcher
removed: static method Environment.newFanOutCachedDispatchers(int, String): DispatcherSupplier
removed: static method Environment.sharedDispatcher(): Dispatcher
removed: static method Environment.tailRecurse(): TailRecurseDispatcher
removed: static method Environment.terminate(): void
removed: static method Environment.timer(): Timer
removed: static method Environment.workDispatcher(): Dispatcher

added: abstract class JdkFlowAdapter
added: static method JdkFlowAdapter.flowPublisherToFlux(Flow.Publisher): Flux
added: static method JdkFlowAdapter.publisherToFlowPublisher(Publisher): Flow.Publisher

removed: interface Dispatcher extends Executor, Resource
removed: interface DispatcherSupplier extends Resource, Supplier
removed: method Dispatcher.backlogSize(): long
removed: method Dispatcher.dispatch(Object, Consumer, Consumer): void
removed: method Dispatcher.inContext(): boolean
removed: method Dispatcher.remainingSlots(): long
removed: method Dispatcher.supportsOrdering(): boolean
removed: method Dispatcher.tryDispatch(Object, Consumer, Consumer): void
added: abstract class Exceptions
added: ctor Scannable.Attr(Object)
added: ctor Scannable.Attr(Object, Function)
added: enum Scannable.Attr.RunStyle
added: final class Disposables
added: interface CorePublisher extends Publisher
added: interface CoreSubscriber extends Subscriber
added: interface Disposable
added: interface Disposable.Composite extends Disposable
added: interface Disposable.Swap extends Disposable, Supplier
added: interface Fuseable
added: interface Fuseable.ConditionalSubscriber extends CoreSubscriber
added: interface Fuseable.QueueSubscription extends Queue, Subscription
added: interface Fuseable.ScalarCallable extends Callable
added: interface Fuseable.SynchronousSubscription extends Fuseable.QueueSubscription
added: interface Scannable
added: method CorePublisher.subscribe(CoreSubscriber): void
added: method CoreSubscriber.currentContext(): Context
added: method CoreSubscriber.onSubscribe(Subscription): void
added: method Disposable.Composite.add(Disposable): boolean
added: method Disposable.Composite.addAll(Collection): boolean
added: method Disposable.Composite.dispose(): void
added: method Disposable.Composite.isDisposed(): boolean
added: method Disposable.Composite.remove(Disposable): boolean
added: method Disposable.Composite.size(): int
added: method Disposable.Swap.replace(Disposable): boolean
added: method Disposable.Swap.update(Disposable): boolean
added: method Disposable.dispose(): void
added: method Disposable.isDisposed(): boolean
added: method Fuseable.ConditionalSubscriber.tryOnNext(Object): boolean
added: method Fuseable.QueueSubscription.add(Object): boolean
added: method Fuseable.QueueSubscription.addAll(Collection): boolean
added: method Fuseable.QueueSubscription.contains(Object): boolean
added: method Fuseable.QueueSubscription.containsAll(Collection): boolean
added: method Fuseable.QueueSubscription.element(): Object
added: method Fuseable.QueueSubscription.iterator(): Iterator
added: method Fuseable.QueueSubscription.offer(Object): boolean
added: method Fuseable.QueueSubscription.peek(): Object
added: method Fuseable.QueueSubscription.remove(): Object
added: method Fuseable.QueueSubscription.remove(Object): boolean
added: method Fuseable.QueueSubscription.removeAll(Collection): boolean
added: method Fuseable.QueueSubscription.requestFusion(int): int
added: method Fuseable.QueueSubscription.retainAll(Collection): boolean
added: method Fuseable.QueueSubscription.toArray(): Object[]
added: method Fuseable.QueueSubscription.toArray(Object[]): Object[]
added: method Fuseable.SynchronousSubscription.requestFusion(int): int
added: method Scannable.Attr.defaultValue(): Object
added: method Scannable.actuals(): Stream
added: method Scannable.inners(): Stream
added: method Scannable.isScanAvailable(): boolean
added: method Scannable.name(): String
added: method Scannable.parents(): Stream
added: method Scannable.scan(Scannable.Attr): Object
added: method Scannable.scanOrDefault(Scannable.Attr, Object): Object
added: method Scannable.scanUnsafe(Scannable.Attr): Object
added: method Scannable.stepName(): String
added: method Scannable.steps(): Stream
added: method Scannable.tags(): Stream
added: method Scannable.tagsDeduplicated(): Map
added: static class Exceptions.SourceException extends Exceptions.ReactiveException
added: static class Scannable.Attr
added: static field Exceptions.AUTO_CLOSE: Consumer
added: static field Exceptions.BACKPRESSURE_ERROR_QUEUE_FULL: String
added: static field Exceptions.TERMINATED: Throwable
added: static field Fuseable.ANY: int
added: static field Fuseable.ASYNC: int
added: static field Fuseable.NONE: int
added: static field Fuseable.QueueSubscription.NOT_SUPPORTED_MESSAGE: String
added: static field Fuseable.SYNC: int
added: static field Fuseable.THREAD_BARRIER: int
added: static field Scannable.Attr.ACTUAL: Scannable.Attr
added: static field Scannable.Attr.ACTUAL_METADATA: Scannable.Attr
added: static field Scannable.Attr.BUFFERED: Scannable.Attr
added: static field Scannable.Attr.CANCELLED: Scannable.Attr
added: static field Scannable.Attr.CAPACITY: Scannable.Attr
added: static field Scannable.Attr.DELAY_ERROR: Scannable.Attr
added: static field Scannable.Attr.ERROR: Scannable.Attr
added: static field Scannable.Attr.LARGE_BUFFERED: Scannable.Attr
added: static field Scannable.Attr.LIFTER: Scannable.Attr
added: static field Scannable.Attr.NAME: Scannable.Attr
added: static field Scannable.Attr.PARENT: Scannable.Attr
added: static field Scannable.Attr.PREFETCH: Scannable.Attr
added: static field Scannable.Attr.REQUESTED_FROM_DOWNSTREAM: Scannable.Attr
added: static field Scannable.Attr.RUN_ON: Scannable.Attr
added: static field Scannable.Attr.RUN_STYLE: Scannable.Attr
added: static field Scannable.Attr.RunStyle.ASYNC: Scannable.Attr.RunStyle
added: static field Scannable.Attr.RunStyle.SYNC: Scannable.Attr.RunStyle
added: static field Scannable.Attr.RunStyle.UNKNOWN: Scannable.Attr.RunStyle
added: static field Scannable.Attr.TAGS: Scannable.Attr
added: static field Scannable.Attr.TERMINATED: Scannable.Attr
added: static field Scannable.OPERATOR_NAME_UNRELATED_WORDS_PATTERN: Pattern
added: static method Disposables.composite(): Disposable.Composite
added: static method Disposables.composite(Disposable[]): Disposable.Composite
added: static method Disposables.composite(Iterable): Disposable.Composite
added: static method Disposables.disposed(): Disposable
added: static method Disposables.never(): Disposable
added: static method Disposables.single(): Disposable
added: static method Disposables.swap(): Disposable.Swap
added: static method Exceptions.addSuppressed(RuntimeException, Throwable): RuntimeException
added: static method Exceptions.addSuppressed(Throwable, Throwable): Throwable
added: static method Exceptions.addThrowable(AtomicReferenceFieldUpdater, Object, Throwable): boolean
added: static method Exceptions.bubble(Throwable): RuntimeException
added: static method Exceptions.duplicateOnSubscribeException(): IllegalStateException
added: static method Exceptions.errorCallbackNotImplemented(Throwable): UnsupportedOperationException
added: static method Exceptions.failWithCancel(): RuntimeException
added: static method Exceptions.failWithOverflow(): IllegalStateException
added: static method Exceptions.failWithOverflow(String): IllegalStateException
added: static method Exceptions.failWithRejected(): RejectedExecutionException
added: static method Exceptions.failWithRejected(String): RejectedExecutionException
added: static method Exceptions.failWithRejected(Throwable): RejectedExecutionException
added: static method Exceptions.failWithRejectedNotTimeCapable(): RejectedExecutionException
added: static method Exceptions.isBubbling(Throwable): boolean
added: static method Exceptions.isCancel(Throwable): boolean
added: static method Exceptions.isErrorCallbackNotImplemented(Throwable): boolean
added: static method Exceptions.isFatal(Throwable): boolean
added: static method Exceptions.isJvmFatal(Throwable): boolean
added: static method Exceptions.isMultiple(Throwable): boolean
added: static method Exceptions.isOverflow(Throwable): boolean
added: static method Exceptions.isRetryExhausted(Throwable): boolean
added: static method Exceptions.isTraceback(Throwable): boolean
added: static method Exceptions.multiple(Iterable): RuntimeException
added: static method Exceptions.multiple(Throwable[]): RuntimeException
added: static method Exceptions.nullOrNegativeRequestException(long): IllegalArgumentException
added: static method Exceptions.propagate(Throwable): RuntimeException
added: static method Exceptions.retryExhausted(String, Throwable): RuntimeException
added: static method Exceptions.terminate(AtomicReferenceFieldUpdater, Object): Throwable
added: static method Exceptions.throwIfFatal(Throwable): void
added: static method Exceptions.throwIfJvmFatal(Throwable): void
added: static method Exceptions.unwrap(Throwable): Throwable
added: static method Exceptions.unwrapMultiple(Throwable): List
added: static method Exceptions.unwrapMultipleExcludingTracebacks(Throwable): List
added: static method Exceptions.wrapSource(Throwable): Throwable
added: static method Fuseable.fusionModeName(int): String
added: static method Fuseable.fusionModeName(int, boolean): String
added: static method Scannable.Attr.RunStyle.valueOf(String): Scannable.Attr.RunStyle
added: static method Scannable.Attr.RunStyle.values(): Scannable.Attr.RunStyle[]
added: static method Scannable.from(Object): Scannable

removed: class PropertiesConfigurationReader implements ConfigurationReader
removed: class ReactorConfiguration
removed: ctor DispatcherConfiguration(String, DispatcherType, Integer, Integer)
removed: ctor PropertiesConfigurationReader()
removed: ctor PropertiesConfigurationReader(String)
removed: ctor ReactorConfiguration(List, String, Properties)
removed: enum DispatcherType
removed: final class DispatcherConfiguration
removed: interface ConfigurationReader
removed: method ConfigurationReader.read(): ReactorConfiguration
removed: method DispatcherConfiguration.getBacklog(): Integer
removed: method DispatcherConfiguration.getName(): String
removed: method DispatcherConfiguration.getSize(): Integer
removed: method DispatcherConfiguration.getType(): DispatcherType
removed: method PropertiesConfigurationReader.loadProfile(String): Properties
removed: method PropertiesConfigurationReader.read(): ReactorConfiguration
removed: method ReactorConfiguration.getAdditionalProperties(): Properties
removed: method ReactorConfiguration.getDefaultDispatcherName(): String
removed: method ReactorConfiguration.getDispatcherConfigurations(): List
removed: static field DispatcherType.DISPATCHER_GROUP: DispatcherType
removed: static field DispatcherType.MPSC: DispatcherType
removed: static field DispatcherType.RING_BUFFER: DispatcherType
removed: static field DispatcherType.SYNCHRONOUS: DispatcherType
removed: static field DispatcherType.THREAD_POOL_EXECUTOR: DispatcherType
removed: static field DispatcherType.WORK_QUEUE: DispatcherType
removed: static method DispatcherType.valueOf(String): DispatcherType
removed: static method DispatcherType.values(): DispatcherType[]

removed: abstract class AbstractLifecycleDispatcher implements Dispatcher
removed: abstract class AbstractLifecycleDispatcher.Task implements Runnable, Recyclable
removed: abstract class MultiThreadDispatcher extends AbstractLifecycleDispatcher
removed: abstract class SingleThreadDispatcher extends AbstractLifecycleDispatcher
removed: class MultiThreadDispatcher.MultiThreadTask extends AbstractLifecycleDispatcher.Task
removed: class SingleThreadDispatcher.SingleThreadTask extends AbstractLifecycleDispatcher.Task
removed: class ThreadPoolExecutorDispatcher extends MultiThreadDispatcher
removed: class TraceableDelegatingDispatcher implements Dispatcher
removed: ctor AbstractLifecycleDispatcher()
removed: ctor AbstractLifecycleDispatcher.Task(AbstractLifecycleDispatcher)
removed: ctor MpscDispatcher(String)
removed: ctor MpscDispatcher(String, int)
removed: ctor MultiThreadDispatcher(int, int)
removed: ctor MultiThreadDispatcher.MultiThreadTask(MultiThreadDispatcher)
removed: ctor RingBufferDispatcher(String)
removed: ctor RingBufferDispatcher(String, int)
removed: ctor RingBufferDispatcher(String, int, Consumer)
removed: ctor RingBufferDispatcher(String, int, Consumer, ProducerType, WaitStrategy)
removed: ctor SingleThreadDispatcher(int)
removed: ctor SingleThreadDispatcher.SingleThreadTask(SingleThreadDispatcher)
removed: ctor SynchronousDispatcher()
removed: ctor TailRecurseDispatcher()
removed: ctor ThreadPoolExecutorDispatcher(int, int)
removed: ctor ThreadPoolExecutorDispatcher(int, int, ExecutorService)
removed: ctor ThreadPoolExecutorDispatcher(int, int, String)
removed: ctor ThreadPoolExecutorDispatcher(int, int, String, BlockingQueue, RejectedExecutionHandler)
removed: ctor TraceableDelegatingDispatcher(Dispatcher)
removed: ctor WorkQueueDispatcher(String, int, int, Consumer)
removed: ctor WorkQueueDispatcher(String, int, int, Consumer, ProducerType, WaitStrategy)
removed: field AbstractLifecycleDispatcher.context: ClassLoader
removed: field SingleThreadDispatcher.backlog: int
removed: field SingleThreadDispatcher.tailRecurseSeq: int
removed: field SingleThreadDispatcher.tailRecursionPile: List
removed: field SingleThreadDispatcher.tailRecursionPileSize: int
removed: final class MpscDispatcher extends SingleThreadDispatcher
removed: final class RingBufferDispatcher extends SingleThreadDispatcher implements WaitingMood
removed: final class SynchronousDispatcher implements Dispatcher
removed: final class TailRecurseDispatcher implements Dispatcher
removed: final class WorkQueueDispatcher extends MultiThreadDispatcher implements WaitingMood
removed: method AbstractLifecycleDispatcher.Task.recycle(): void
removed: method AbstractLifecycleDispatcher.Task.setData(Object): AbstractLifecycleDispatcher.Task
removed: method AbstractLifecycleDispatcher.Task.setErrorConsumer(Consumer): AbstractLifecycleDispatcher.Task
removed: method AbstractLifecycleDispatcher.Task.setEventConsumer(Consumer): AbstractLifecycleDispatcher.Task
removed: method AbstractLifecycleDispatcher.alive(): boolean
removed: method AbstractLifecycleDispatcher.allocateRecursiveTask(): AbstractLifecycleDispatcher.Task
removed: method AbstractLifecycleDispatcher.allocateTask(): AbstractLifecycleDispatcher.Task
removed: method AbstractLifecycleDispatcher.awaitAndShutdown(): boolean
removed: method AbstractLifecycleDispatcher.dispatch(Object, Consumer, Consumer): void
removed: method AbstractLifecycleDispatcher.execute(AbstractLifecycleDispatcher.Task): void
removed: method AbstractLifecycleDispatcher.execute(Runnable): void
removed: method AbstractLifecycleDispatcher.forceShutdown(): void
removed: method AbstractLifecycleDispatcher.getContext(): ClassLoader
removed: method AbstractLifecycleDispatcher.inContext(): boolean
removed: method AbstractLifecycleDispatcher.scheduleLater(AbstractLifecycleDispatcher.Task): void
removed: method AbstractLifecycleDispatcher.shutdown(): void
removed: method AbstractLifecycleDispatcher.toString(): String
removed: method AbstractLifecycleDispatcher.tryAllocateTask(): AbstractLifecycleDispatcher.Task
removed: method AbstractLifecycleDispatcher.tryDispatch(Object, Consumer, Consumer): void
removed: method MpscDispatcher.allocateTask(): AbstractLifecycleDispatcher.Task
removed: method MpscDispatcher.awaitAndShutdown(long, TimeUnit): boolean
removed: method MpscDispatcher.execute(AbstractLifecycleDispatcher.Task): void
removed: method MpscDispatcher.forceShutdown(): void
removed: method MpscDispatcher.remainingSlots(): long
removed: method MpscDispatcher.shutdown(): void
removed: method MpscDispatcher.tryAllocateTask(): AbstractLifecycleDispatcher.Task
removed: method MultiThreadDispatcher.MultiThreadTask.run(): void
removed: method MultiThreadDispatcher.allocateRecursiveTask(): AbstractLifecycleDispatcher.Task
removed: method MultiThreadDispatcher.allocateTask(): AbstractLifecycleDispatcher.Task
removed: method MultiThreadDispatcher.backlogSize(): long
removed: method MultiThreadDispatcher.poolSize(): int
removed: method MultiThreadDispatcher.scheduleLater(AbstractLifecycleDispatcher.Task): void
removed: method MultiThreadDispatcher.supportsOrdering(): boolean
removed: method MultiThreadDispatcher.tryAllocateTask(): AbstractLifecycleDispatcher.Task
removed: method RingBufferDispatcher.allocateTask(): AbstractLifecycleDispatcher.Task
removed: method RingBufferDispatcher.awaitAndShutdown(long, TimeUnit): boolean
removed: method RingBufferDispatcher.calm(): void
removed: method RingBufferDispatcher.execute(AbstractLifecycleDispatcher.Task): void
removed: method RingBufferDispatcher.forceShutdown(): void
removed: method RingBufferDispatcher.nervous(): void
removed: method RingBufferDispatcher.remainingSlots(): long
removed: method RingBufferDispatcher.shutdown(): void
removed: method RingBufferDispatcher.tryAllocateTask(): AbstractLifecycleDispatcher.Task
removed: method SingleThreadDispatcher.SingleThreadTask.run(): void
removed: method SingleThreadDispatcher.allocateRecursiveTask(): AbstractLifecycleDispatcher.Task
removed: method SingleThreadDispatcher.allocateTask(): AbstractLifecycleDispatcher.Task
removed: method SingleThreadDispatcher.backlogSize(): long
removed: method SingleThreadDispatcher.expandTailRecursionPile(int): void
removed: method SingleThreadDispatcher.getTailRecursionPileSize(): int
removed: method SingleThreadDispatcher.supportsOrdering(): boolean
removed: method SynchronousDispatcher.alive(): boolean
removed: method SynchronousDispatcher.awaitAndShutdown(): boolean
removed: method SynchronousDispatcher.awaitAndShutdown(long, TimeUnit): boolean
removed: method SynchronousDispatcher.backlogSize(): long
removed: method SynchronousDispatcher.dispatch(Object, Consumer, Consumer): void
removed: method SynchronousDispatcher.execute(Runnable): void
removed: method SynchronousDispatcher.forceShutdown(): void
removed: method SynchronousDispatcher.inContext(): boolean
removed: method SynchronousDispatcher.remainingSlots(): long
removed: method SynchronousDispatcher.shutdown(): void
removed: method SynchronousDispatcher.supportsOrdering(): boolean
removed: method SynchronousDispatcher.toString(): String
removed: method SynchronousDispatcher.tryDispatch(Object, Consumer, Consumer): void
removed: method TailRecurseDispatcher.alive(): boolean
removed: method TailRecurseDispatcher.awaitAndShutdown(): boolean
removed: method TailRecurseDispatcher.awaitAndShutdown(long, TimeUnit): boolean
removed: method TailRecurseDispatcher.backlogSize(): long
removed: method TailRecurseDispatcher.dispatch(Object, Consumer, Consumer): void
removed: method TailRecurseDispatcher.execute(Runnable): void
removed: method TailRecurseDispatcher.forceShutdown(): void
removed: method TailRecurseDispatcher.inContext(): boolean
removed: method TailRecurseDispatcher.remainingSlots(): long
removed: method TailRecurseDispatcher.shutdown(): void
removed: method TailRecurseDispatcher.supportsOrdering(): boolean
removed: method TailRecurseDispatcher.toString(): String
removed: method TailRecurseDispatcher.tryDispatch(Object, Consumer, Consumer): void
removed: method ThreadPoolExecutorDispatcher.awaitAndShutdown(long, TimeUnit): boolean
removed: method ThreadPoolExecutorDispatcher.execute(AbstractLifecycleDispatcher.Task): void
removed: method ThreadPoolExecutorDispatcher.execute(Runnable): void
removed: method ThreadPoolExecutorDispatcher.forceShutdown(): void
removed: method ThreadPoolExecutorDispatcher.remainingSlots(): long
removed: method ThreadPoolExecutorDispatcher.shutdown(): void
removed: method TraceableDelegatingDispatcher.alive(): boolean
removed: method TraceableDelegatingDispatcher.awaitAndShutdown(): boolean
removed: method TraceableDelegatingDispatcher.awaitAndShutdown(long, TimeUnit): boolean
removed: method TraceableDelegatingDispatcher.backlogSize(): long
removed: method TraceableDelegatingDispatcher.dispatch(Object, Consumer, Consumer): void
removed: method TraceableDelegatingDispatcher.execute(Runnable): void
removed: method TraceableDelegatingDispatcher.forceShutdown(): void
removed: method TraceableDelegatingDispatcher.inContext(): boolean
removed: method TraceableDelegatingDispatcher.remainingSlots(): long
removed: method TraceableDelegatingDispatcher.shutdown(): void
removed: method TraceableDelegatingDispatcher.supportsOrdering(): boolean
removed: method TraceableDelegatingDispatcher.tryDispatch(Object, Consumer, Consumer): void
removed: method WorkQueueDispatcher.allocateTask(): AbstractLifecycleDispatcher.Task
removed: method WorkQueueDispatcher.awaitAndShutdown(long, TimeUnit): boolean
removed: method WorkQueueDispatcher.calm(): void
removed: method WorkQueueDispatcher.execute(AbstractLifecycleDispatcher.Task): void
removed: method WorkQueueDispatcher.forceShutdown(): void
removed: method WorkQueueDispatcher.nervous(): void
removed: method WorkQueueDispatcher.remainingSlots(): long
removed: method WorkQueueDispatcher.shutdown(): void
removed: method WorkQueueDispatcher.tryAllocateTask(): AbstractLifecycleDispatcher.Task
removed: static field AbstractLifecycleDispatcher.DEFAULT_BUFFER_SIZE: int
removed: static field SynchronousDispatcher.INSTANCE: SynchronousDispatcher
removed: static field TailRecurseDispatcher.INSTANCE: TailRecurseDispatcher
removed: static method AbstractLifecycleDispatcher.route(AbstractLifecycleDispatcher.Task): void

removed: class ParkWaitStrategy implements WaitStrategy
removed: ctor AgileWaitingStrategy()
removed: ctor AgileWaitingStrategy(WaitStrategy, WaitStrategy)
removed: ctor ParkWaitStrategy()
removed: ctor ParkWaitStrategy(long)
removed: final class AgileWaitingStrategy implements WaitStrategy, WaitingMood
removed: interface WaitingMood
removed: method AgileWaitingStrategy.calm(): void
removed: method AgileWaitingStrategy.current(): WaitStrategy
removed: method AgileWaitingStrategy.nervous(): void
removed: method AgileWaitingStrategy.signalAllWhenBlocking(): void
removed: method AgileWaitingStrategy.waitFor(long, Sequence, Sequence, SequenceBarrier): long
removed: method ParkWaitStrategy.signalAllWhenBlocking(): void
removed: method ParkWaitStrategy.waitFor(long, Sequence, Sequence, SequenceBarrier): long
removed: method WaitingMood.calm(): void
removed: method WaitingMood.nervous(): void

removed: class PlatformDependent
removed: ctor PlatformDependent()
removed: static method PlatformDependent.hasUnsafe(): boolean
removed: static method PlatformDependent.newAtomicReferenceFieldUpdater(Class, String): AtomicReferenceFieldUpdater

added: abstract class DefaultSignalListener implements SignalListener
added: ctor DefaultSignalListener()
added: interface SignalListener
added: interface SignalListenerFactory
added: method DefaultSignalListener.doAfterComplete(): void
added: method DefaultSignalListener.doAfterError(Throwable): void
added: method DefaultSignalListener.doFinally(SignalType): void
added: method DefaultSignalListener.doFirst(): void
added: method DefaultSignalListener.doOnCancel(): void
added: method DefaultSignalListener.doOnComplete(): void
added: method DefaultSignalListener.doOnError(Throwable): void
added: method DefaultSignalListener.doOnFusion(int): void
added: method DefaultSignalListener.doOnMalformedOnComplete(): void
added: method DefaultSignalListener.doOnMalformedOnError(Throwable): void
added: method DefaultSignalListener.doOnMalformedOnNext(Object): void
added: method DefaultSignalListener.doOnNext(Object): void
added: method DefaultSignalListener.doOnRequest(long): void
added: method DefaultSignalListener.doOnSubscription(): void
added: method DefaultSignalListener.getFusionMode(): int
added: method DefaultSignalListener.handleListenerError(Throwable): void
added: method SignalListener.addToContext(Context): Context
added: method SignalListener.doAfterComplete(): void
added: method SignalListener.doAfterError(Throwable): void
added: method SignalListener.doFinally(SignalType): void
added: method SignalListener.doFirst(): void
added: method SignalListener.doOnCancel(): void
added: method SignalListener.doOnComplete(): void
added: method SignalListener.doOnError(Throwable): void
added: method SignalListener.doOnFusion(int): void
added: method SignalListener.doOnMalformedOnComplete(): void
added: method SignalListener.doOnMalformedOnError(Throwable): void
added: method SignalListener.doOnMalformedOnNext(Object): void
added: method SignalListener.doOnNext(Object): void
added: method SignalListener.doOnRequest(long): void
added: method SignalListener.doOnSubscription(): void
added: method SignalListener.handleListenerError(Throwable): void
added: method SignalListenerFactory.createListener(Publisher, ContextView, Object): SignalListener
added: method SignalListenerFactory.initializePublisherState(Publisher): Object

removed: abstract class ExecutorPoweredProcessor extends ReactorProcessor
removed: abstract class ReactorProcessor implements Processor, Consumer, NonBlocking, Resource
removed: ctor ExecutorPoweredProcessor(String, ExecutorService, boolean)
removed: ctor MutableSignal()
removed: ctor ReactorProcessor(boolean)
removed: enum MutableSignal.Type
removed: field ExecutorPoweredProcessor.executor: ExecutorService
removed: field MutableSignal.error: Throwable
removed: field MutableSignal.type: MutableSignal.Type
removed: field MutableSignal.value: Object
removed: field ReactorProcessor.autoCancel: boolean
removed: field ReactorProcessor.upstreamSubscription: Subscription
removed: final class CancelException extends RuntimeException
removed: final class InsufficientCapacityException extends RuntimeException
removed: final class MutableSignal
removed: final class RingBufferProcessor extends ExecutorPoweredProcessor
removed: final class RingBufferWorkProcessor extends ExecutorPoweredProcessor
removed: method CancelException.fillInStackTrace(): Throwable
removed: method ExecutorPoweredProcessor.alive(): boolean
removed: method ExecutorPoweredProcessor.awaitAndShutdown(): boolean
removed: method ExecutorPoweredProcessor.awaitAndShutdown(long, TimeUnit): boolean
removed: method ExecutorPoweredProcessor.forceShutdown(): void
removed: method ExecutorPoweredProcessor.onComplete(): void
removed: method ExecutorPoweredProcessor.shutdown(): void
removed: method InsufficientCapacityException.fillInStackTrace(): Throwable
removed: method ReactorProcessor.accept(Object): void
removed: method ReactorProcessor.decrementSubscribers(): int
removed: method ReactorProcessor.getAvailableCapacity(): long
removed: method ReactorProcessor.getCapacity(): long
removed: method ReactorProcessor.incrementSubscribers(): boolean
removed: method ReactorProcessor.isReactivePull(Dispatcher, long): boolean
removed: method ReactorProcessor.onSubscribe(Subscription): void
removed: method RingBufferProcessor.getAvailableCapacity(): long
removed: method RingBufferProcessor.getCapacity(): long
removed: method RingBufferProcessor.onComplete(): void
removed: method RingBufferProcessor.onError(Throwable): void
removed: method RingBufferProcessor.onNext(Object): void
removed: method RingBufferProcessor.subscribe(Subscriber): void
removed: method RingBufferProcessor.toString(): String
removed: method RingBufferProcessor.writeWith(Publisher): Publisher
removed: method RingBufferWorkProcessor.getAvailableCapacity(): long
removed: method RingBufferWorkProcessor.getCapacity(): long
removed: method RingBufferWorkProcessor.onComplete(): void
removed: method RingBufferWorkProcessor.onError(Throwable): void
removed: method RingBufferWorkProcessor.onNext(Object): void
removed: method RingBufferWorkProcessor.subscribe(Subscriber): void
removed: method RingBufferWorkProcessor.toString(): String
removed: method RingBufferWorkProcessor.writeWith(Publisher): Publisher
removed: static field CancelException.INSTANCE: CancelException
removed: static field CancelException.TRACE_CANCEL: boolean
removed: static field InsufficientCapacityException.TRACE_NOCAPACITY: boolean
removed: static field MutableSignal.Type.COMPLETE: MutableSignal.Type
removed: static field MutableSignal.Type.ERROR: MutableSignal.Type
removed: static field MutableSignal.Type.NEXT: MutableSignal.Type
removed: static field ReactorProcessor.SMALL_BUFFER_SIZE: int
removed: static field ReactorProcessor.SUBSCRIBER_COUNT: AtomicIntegerFieldUpdater
removed: static method CancelException.get(): CancelException
removed: static method InsufficientCapacityException.get(): InsufficientCapacityException
removed: static method MutableSignal.Type.valueOf(String): MutableSignal.Type
removed: static method MutableSignal.Type.values(): MutableSignal.Type[]
removed: static method RingBufferProcessor.create(): RingBufferProcessor
removed: static method RingBufferProcessor.create(ExecutorService): RingBufferProcessor
removed: static method RingBufferProcessor.create(ExecutorService, boolean): RingBufferProcessor
removed: static method RingBufferProcessor.create(ExecutorService, int): RingBufferProcessor
removed: static method RingBufferProcessor.create(ExecutorService, int, WaitStrategy): RingBufferProcessor
removed: static method RingBufferProcessor.create(ExecutorService, int, WaitStrategy, boolean): RingBufferProcessor
removed: static method RingBufferProcessor.create(ExecutorService, int, boolean): RingBufferProcessor
removed: static method RingBufferProcessor.create(String, int): RingBufferProcessor
removed: static method RingBufferProcessor.create(String, int, WaitStrategy): RingBufferProcessor
removed: static method RingBufferProcessor.create(String, int, WaitStrategy, boolean): RingBufferProcessor
removed: static method RingBufferProcessor.create(String, int, boolean): RingBufferProcessor
removed: static method RingBufferProcessor.create(boolean): RingBufferProcessor
removed: static method RingBufferProcessor.share(): RingBufferProcessor
removed: static method RingBufferProcessor.share(ExecutorService): RingBufferProcessor
removed: static method RingBufferProcessor.share(ExecutorService, boolean): RingBufferProcessor
removed: static method RingBufferProcessor.share(ExecutorService, int): RingBufferProcessor
removed: static method RingBufferProcessor.share(ExecutorService, int, WaitStrategy): RingBufferProcessor
removed: static method RingBufferProcessor.share(ExecutorService, int, WaitStrategy, boolean): RingBufferProcessor
removed: static method RingBufferProcessor.share(ExecutorService, int, boolean): RingBufferProcessor
removed: static method RingBufferProcessor.share(String, int): RingBufferProcessor
removed: static method RingBufferProcessor.share(String, int, WaitStrategy): RingBufferProcessor
removed: static method RingBufferProcessor.share(String, int, WaitStrategy, boolean): RingBufferProcessor
removed: static method RingBufferProcessor.share(String, int, boolean): RingBufferProcessor
removed: static method RingBufferProcessor.share(boolean): RingBufferProcessor
removed: static method RingBufferWorkProcessor.create(): RingBufferWorkProcessor
removed: static method RingBufferWorkProcessor.create(ExecutorService): RingBufferWorkProcessor
removed: static method RingBufferWorkProcessor.create(ExecutorService, boolean): RingBufferWorkProcessor
removed: static method RingBufferWorkProcessor.create(ExecutorService, int): RingBufferWorkProcessor
removed: static method RingBufferWorkProcessor.create(ExecutorService, int, WaitStrategy): RingBufferWorkProcessor
removed: static method RingBufferWorkProcessor.create(ExecutorService, int, WaitStrategy, boolean): RingBufferWorkProcessor
removed: static method RingBufferWorkProcessor.create(ExecutorService, int, boolean): RingBufferWorkProcessor
removed: static method RingBufferWorkProcessor.create(String, int): RingBufferWorkProcessor
removed: static method RingBufferWorkProcessor.create(String, int, WaitStrategy): RingBufferWorkProcessor
removed: static method RingBufferWorkProcessor.create(String, int, WaitStrategy, boolean): RingBufferWorkProcessor
removed: static method RingBufferWorkProcessor.create(String, int, boolean): RingBufferWorkProcessor
removed: static method RingBufferWorkProcessor.create(boolean): RingBufferWorkProcessor
removed: static method RingBufferWorkProcessor.share(): RingBufferWorkProcessor
removed: static method RingBufferWorkProcessor.share(ExecutorService): RingBufferWorkProcessor
removed: static method RingBufferWorkProcessor.share(ExecutorService, boolean): RingBufferWorkProcessor
removed: static method RingBufferWorkProcessor.share(ExecutorService, int): RingBufferWorkProcessor
removed: static method RingBufferWorkProcessor.share(ExecutorService, int, WaitStrategy): RingBufferWorkProcessor
removed: static method RingBufferWorkProcessor.share(ExecutorService, int, WaitStrategy, boolean): RingBufferWorkProcessor
removed: static method RingBufferWorkProcessor.share(ExecutorService, int, boolean): RingBufferWorkProcessor
removed: static method RingBufferWorkProcessor.share(String, int): RingBufferWorkProcessor
removed: static method RingBufferWorkProcessor.share(String, int, WaitStrategy): RingBufferWorkProcessor
removed: static method RingBufferWorkProcessor.share(String, int, WaitStrategy, boolean): RingBufferWorkProcessor
removed: static method RingBufferWorkProcessor.share(String, int, boolean): RingBufferWorkProcessor
removed: static method RingBufferWorkProcessor.share(boolean): RingBufferWorkProcessor

removed: final class RingBufferSubscriberUtils
removed: final class SingleUseExecutor implements ExecutorService
removed: method SingleUseExecutor.awaitTermination(long, TimeUnit): boolean
removed: method SingleUseExecutor.execute(Runnable): void
removed: method SingleUseExecutor.invokeAll(Collection): List
removed: method SingleUseExecutor.invokeAll(Collection, long, TimeUnit): List
removed: method SingleUseExecutor.invokeAny(Collection): Object
removed: method SingleUseExecutor.invokeAny(Collection, long, TimeUnit): Object
removed: method SingleUseExecutor.isShutdown(): boolean
removed: method SingleUseExecutor.isTerminated(): boolean
removed: method SingleUseExecutor.shutdown(): void
removed: method SingleUseExecutor.shutdownNow(): List
removed: method SingleUseExecutor.submit(Callable): Future
removed: method SingleUseExecutor.submit(Runnable): Future
removed: method SingleUseExecutor.submit(Runnable, Object): Future
removed: static method RingBufferSubscriberUtils.onComplete(RingBuffer): void
removed: static method RingBufferSubscriberUtils.onError(Throwable, RingBuffer): void
removed: static method RingBufferSubscriberUtils.onNext(Object, RingBuffer): void
removed: static method RingBufferSubscriberUtils.route(MutableSignal, Subscriber): void
removed: static method RingBufferSubscriberUtils.routeOnce(MutableSignal, Subscriber): void
removed: static method RingBufferSubscriberUtils.waitRequestOrTerminalEvent(Sequence, RingBuffer, SequenceBarrier, Subscriber, AtomicBoolean): boolean
removed: static method RingBufferSubscriberUtils.writeWith(Publisher, RingBuffer): Publisher
removed: static method SingleUseExecutor.create(String): ExecutorService
removed: static method SingleUseExecutor.wrap(ExecutorService): ExecutorService

added: abstract class BaseSubscriber implements CoreSubscriber, Subscription, Disposable
added: abstract class ConnectableFlux extends Flux
added: abstract class Flux implements CorePublisher
added: abstract class FluxOperator extends Flux implements Scannable
added: abstract class FluxProcessor extends Flux implements Processor, CoreSubscriber, Scannable, Disposable, ContextHolder
added: abstract class GroupedFlux extends Flux
added: abstract class Hooks
added: abstract class Mono implements CorePublisher
added: abstract class MonoOperator extends Mono implements Scannable
added: abstract class MonoProcessor extends Mono implements Processor, CoreSubscriber, Disposable, Subscription, Scannable
added: abstract class Operators
added: abstract class ParallelFlux implements CorePublisher
added: class SinkOneSerialized extends SinkEmptySerialized implements InternalOneSink, ContextHolder
added: ctor BaseSubscriber()
added: ctor ConnectableFlux()
added: ctor Flux()
added: ctor FluxOperator(Flux)
added: ctor FluxProcessor()
added: ctor GroupedFlux()
added: ctor Mono()
added: ctor MonoOperator(Mono)
added: ctor MonoProcessor()
added: ctor Operators.DeferredSubscription()
added: ctor Operators.MonoSubscriber(CoreSubscriber)
added: ctor ParallelFlux()
added: ctor SinkOneSerialized(Sinks.One, ContextHolder)
added: ctor Sinks.EmissionException(Sinks.EmitResult)
added: ctor Sinks.EmissionException(Sinks.EmitResult, String)
added: ctor Sinks.EmissionException(Throwable, Sinks.EmitResult)
added: ctor UnicastProcessor(Queue)
added: ctor UnicastProcessor(Queue, Consumer, Disposable)
added: ctor UnicastProcessor(Queue, Disposable)
added: enum BufferOverflowStrategy
added: enum FluxSink.OverflowStrategy
added: enum SignalType
added: enum Sinks.EmitResult
added: field FluxOperator.source: Flux
added: field MonoOperator.source: Mono
added: field Operators.MonoSubscriber.actual: CoreSubscriber
added: field Operators.MonoSubscriber.value: Object
added: final class DirectProcessor extends FluxProcessor implements DirectInnerContainer
added: final class EmitterProcessor extends FluxProcessor implements InternalManySink, Sinks.ManyWithUpstream
added: final class ReplayProcessor extends FluxProcessor implements Fuseable, InternalManySink
added: final class Sinks
added: final class UnicastProcessor extends FluxProcessor implements Fuseable.QueueSubscription, Fuseable, InnerOperator, InternalManySink
added: interface FluxSink
added: interface MonoSink
added: interface Signal extends Supplier, Consumer
added: interface Sinks.EmitFailureHandler
added: interface Sinks.Empty extends Scannable
added: interface Sinks.Many extends Scannable
added: interface Sinks.ManySpec
added: interface Sinks.ManyWithUpstream extends Sinks.Many
added: interface Sinks.ManyWithUpstreamUnsafeSpec
added: interface Sinks.MulticastReplaySpec
added: interface Sinks.MulticastSpec
added: interface Sinks.One extends Sinks.Empty
added: interface Sinks.RootSpec
added: interface Sinks.UnicastSpec
added: interface SynchronousSink
added: interface Timed extends Supplier
added: method BaseSubscriber.cancel(): void
added: method BaseSubscriber.dispose(): void
added: method BaseSubscriber.hookFinally(SignalType): void
added: method BaseSubscriber.hookOnCancel(): void
added: method BaseSubscriber.hookOnComplete(): void
added: method BaseSubscriber.hookOnError(Throwable): void
added: method BaseSubscriber.hookOnNext(Object): void
added: method BaseSubscriber.hookOnSubscribe(Subscription): void
added: method BaseSubscriber.isDisposed(): boolean
added: method BaseSubscriber.onComplete(): void
added: method BaseSubscriber.onError(Throwable): void
added: method BaseSubscriber.onNext(Object): void
added: method BaseSubscriber.onSubscribe(Subscription): void
added: method BaseSubscriber.request(long): void
added: method BaseSubscriber.requestUnbounded(): void
added: method BaseSubscriber.toString(): String
added: method BaseSubscriber.upstream(): Subscription
added: method ConnectableFlux.autoConnect(): Flux
added: method ConnectableFlux.autoConnect(int): Flux
added: method ConnectableFlux.autoConnect(int, Consumer): Flux
added: method ConnectableFlux.connect(): Disposable
added: method ConnectableFlux.connect(Consumer): void
added: method ConnectableFlux.hide(): ConnectableFlux
added: method ConnectableFlux.refCount(): Flux
added: method ConnectableFlux.refCount(int): Flux
added: method ConnectableFlux.refCount(int, Duration): Flux
added: method ConnectableFlux.refCount(int, Duration, Scheduler): Flux
added: method DirectProcessor.add(SinkManyBestEffort.DirectInner): boolean
added: method DirectProcessor.currentContext(): Context
added: method DirectProcessor.downstreamCount(): long
added: method DirectProcessor.getError(): Throwable
added: method DirectProcessor.getPrefetch(): int
added: method DirectProcessor.hasDownstreams(): boolean
added: method DirectProcessor.inners(): Stream
added: method DirectProcessor.isIdentityProcessor(): boolean
added: method DirectProcessor.isTerminated(): boolean
added: method DirectProcessor.onComplete(): void
added: method DirectProcessor.onError(Throwable): void
added: method DirectProcessor.onNext(Object): void
added: method DirectProcessor.onSubscribe(Subscription): void
added: method DirectProcessor.remove(SinkManyBestEffort.DirectInner): void
added: method DirectProcessor.subscribe(CoreSubscriber): void
added: method EmitterProcessor.asFlux(): Flux
added: method EmitterProcessor.currentContext(): Context
added: method EmitterProcessor.currentSubscriberCount(): int
added: method EmitterProcessor.downstreamCount(): long
added: method EmitterProcessor.getBufferSize(): int
added: method EmitterProcessor.getError(): Throwable
added: method EmitterProcessor.getPending(): int
added: method EmitterProcessor.getPrefetch(): int
added: method EmitterProcessor.inners(): Stream
added: method EmitterProcessor.isCancelled(): boolean
added: method EmitterProcessor.isDisposed(): boolean
added: method EmitterProcessor.isIdentityProcessor(): boolean
added: method EmitterProcessor.isTerminated(): boolean
added: method EmitterProcessor.onComplete(): void
added: method EmitterProcessor.onError(Throwable): void
added: method EmitterProcessor.onNext(Object): void
added: method EmitterProcessor.onSubscribe(Subscription): void
added: method EmitterProcessor.scanUnsafe(Scannable.Attr): Object
added: method EmitterProcessor.subscribe(CoreSubscriber): void
added: method EmitterProcessor.subscribeTo(Publisher): Disposable
added: method EmitterProcessor.tryEmitComplete(): Sinks.EmitResult
added: method EmitterProcessor.tryEmitError(Throwable): Sinks.EmitResult
added: method EmitterProcessor.tryEmitNext(Object): Sinks.EmitResult
added: method Flux.all(Predicate): Mono
added: method Flux.any(Predicate): Mono
added: method Flux.as(Function): Object
added: method Flux.blockFirst(): Object
added: method Flux.blockFirst(Duration): Object
added: method Flux.blockLast(): Object
added: method Flux.blockLast(Duration): Object
added: method Flux.buffer(): Flux
added: method Flux.buffer(Duration): Flux
added: method Flux.buffer(Duration, Duration): Flux
added: method Flux.buffer(Duration, Duration, Scheduler): Flux
added: method Flux.buffer(Duration, Scheduler): Flux
added: method Flux.buffer(Publisher): Flux
added: method Flux.buffer(Publisher, Supplier): Flux
added: method Flux.buffer(int): Flux
added: method Flux.buffer(int, Supplier): Flux
added: method Flux.buffer(int, int): Flux
added: method Flux.buffer(int, int, Supplier): Flux
added: method Flux.bufferTimeout(int, Duration): Flux
added: method Flux.bufferTimeout(int, Duration, Scheduler): Flux
added: method Flux.bufferTimeout(int, Duration, Scheduler, Supplier): Flux
added: method Flux.bufferTimeout(int, Duration, Scheduler, Supplier, boolean): Flux
added: method Flux.bufferTimeout(int, Duration, Scheduler, boolean): Flux
added: method Flux.bufferTimeout(int, Duration, Supplier): Flux
added: method Flux.bufferTimeout(int, Duration, Supplier, boolean): Flux
added: method Flux.bufferTimeout(int, Duration, boolean): Flux
added: method Flux.bufferUntil(Predicate): Flux
added: method Flux.bufferUntil(Predicate, boolean): Flux
added: method Flux.bufferUntilChanged(): Flux
added: method Flux.bufferUntilChanged(Function): Flux
added: method Flux.bufferUntilChanged(Function, BiPredicate): Flux
added: method Flux.bufferWhen(Publisher, Function): Flux
added: method Flux.bufferWhen(Publisher, Function, Supplier): Flux
added: method Flux.bufferWhile(Predicate): Flux
added: method Flux.cache(): Flux
added: method Flux.cache(Duration): Flux
added: method Flux.cache(Duration, Scheduler): Flux
added: method Flux.cache(int): Flux
added: method Flux.cache(int, Duration): Flux
added: method Flux.cache(int, Duration, Scheduler): Flux
added: method Flux.cancelOn(Scheduler): Flux
added: method Flux.cast(Class): Flux
added: method Flux.checkpoint(): Flux
added: method Flux.checkpoint(String): Flux
added: method Flux.checkpoint(String, boolean): Flux
added: method Flux.collect(Collector): Mono
added: method Flux.collect(Supplier, BiConsumer): Mono
added: method Flux.collectList(): Mono
added: method Flux.collectMap(Function): Mono
added: method Flux.collectMap(Function, Function): Mono
added: method Flux.collectMap(Function, Function, Supplier): Mono
added: method Flux.collectMultimap(Function): Mono
added: method Flux.collectMultimap(Function, Function): Mono
added: method Flux.collectMultimap(Function, Function, Supplier): Mono
added: method Flux.collectSortedList(): Mono
added: method Flux.collectSortedList(Comparator): Mono
added: method Flux.concatMap(Function): Flux
added: method Flux.concatMap(Function, int): Flux
added: method Flux.concatMapDelayError(Function): Flux
added: method Flux.concatMapDelayError(Function, boolean, int): Flux
added: method Flux.concatMapDelayError(Function, int): Flux
added: method Flux.concatMapIterable(Function): Flux
added: method Flux.concatMapIterable(Function, int): Flux
added: method Flux.concatWith(Publisher): Flux
added: method Flux.concatWithValues(Object[]): Flux
added: method Flux.contextCapture(): Flux
added: method Flux.contextWrite(ContextView): Flux
added: method Flux.contextWrite(Function): Flux
added: method Flux.count(): Mono
added: method Flux.defaultIfEmpty(Object): Flux
added: method Flux.delayElements(Duration): Flux
added: method Flux.delayElements(Duration, Scheduler): Flux
added: method Flux.delaySequence(Duration): Flux
added: method Flux.delaySequence(Duration, Scheduler): Flux
added: method Flux.delaySubscription(Duration): Flux
added: method Flux.delaySubscription(Duration, Scheduler): Flux
added: method Flux.delaySubscription(Publisher): Flux
added: method Flux.delayUntil(Function): Flux
added: method Flux.dematerialize(): Flux
added: method Flux.distinct(): Flux
added: method Flux.distinct(Function): Flux
added: method Flux.distinct(Function, Supplier): Flux
added: method Flux.distinct(Function, Supplier, BiPredicate, Consumer): Flux
added: method Flux.distinctUntilChanged(): Flux
added: method Flux.distinctUntilChanged(Function): Flux
added: method Flux.distinctUntilChanged(Function, BiPredicate): Flux
added: method Flux.doAfterTerminate(Runnable): Flux
added: method Flux.doFinally(Consumer): Flux
added: method Flux.doFirst(Runnable): Flux
added: method Flux.doOnCancel(Runnable): Flux
added: method Flux.doOnComplete(Runnable): Flux
added: method Flux.doOnDiscard(Class, Consumer): Flux
added: method Flux.doOnEach(Consumer): Flux
added: method Flux.doOnError(Class, Consumer): Flux
added: method Flux.doOnError(Consumer): Flux
added: method Flux.doOnError(Predicate, Consumer): Flux
added: method Flux.doOnNext(Consumer): Flux
added: method Flux.doOnRequest(LongConsumer): Flux
added: method Flux.doOnSubscribe(Consumer): Flux
added: method Flux.doOnTerminate(Runnable): Flux
added: method Flux.elapsed(): Flux
added: method Flux.elapsed(Scheduler): Flux
added: method Flux.elementAt(int): Mono
added: method Flux.elementAt(int, Object): Mono
added: method Flux.expand(Function): Flux
added: method Flux.expand(Function, int): Flux
added: method Flux.expandDeep(Function): Flux
added: method Flux.expandDeep(Function, int): Flux
added: method Flux.filter(Predicate): Flux
added: method Flux.filterWhen(Function): Flux
added: method Flux.filterWhen(Function, int): Flux
added: method Flux.flatMap(Function): Flux
added: method Flux.flatMap(Function, Function, Supplier): Flux
added: method Flux.flatMap(Function, int): Flux
added: method Flux.flatMap(Function, int, int): Flux
added: method Flux.flatMapDelayError(Function, int, int): Flux
added: method Flux.flatMapIterable(Function): Flux
added: method Flux.flatMapIterable(Function, int): Flux
added: method Flux.flatMapSequential(Function): Flux
added: method Flux.flatMapSequential(Function, int): Flux
added: method Flux.flatMapSequential(Function, int, int): Flux
added: method Flux.flatMapSequentialDelayError(Function, int, int): Flux
added: method Flux.getPrefetch(): int
added: method Flux.groupBy(Function): Flux
added: method Flux.groupBy(Function, Function): Flux
added: method Flux.groupBy(Function, Function, int): Flux
added: method Flux.groupBy(Function, int): Flux
added: method Flux.groupJoin(Publisher, Function, Function, BiFunction): Flux
added: method Flux.handle(BiConsumer): Flux
added: method Flux.hasElement(Object): Mono
added: method Flux.hasElements(): Mono
added: method Flux.hide(): Flux
added: method Flux.ignoreElements(): Mono
added: method Flux.index(): Flux
added: method Flux.index(BiFunction): Flux
added: method Flux.join(Publisher, Function, Function, BiFunction): Flux
added: method Flux.last(): Mono
added: method Flux.last(Object): Mono
added: method Flux.limitRate(int): Flux
added: method Flux.limitRate(int, int): Flux
added: method Flux.limitRequest(long): Flux
added: method Flux.log(): Flux
added: method Flux.log(Logger): Flux
added: method Flux.log(Logger, Level, boolean, SignalType[]): Flux
added: method Flux.log(String): Flux
added: method Flux.log(String, Level, SignalType[]): Flux
added: method Flux.log(String, Level, boolean, SignalType[]): Flux
added: method Flux.map(Function): Flux
added: method Flux.mapNotNull(Function): Flux
added: method Flux.materialize(): Flux
added: method Flux.mergeComparingWith(Publisher, Comparator): Flux
added: method Flux.mergeOrderedWith(Publisher, Comparator): Flux
added: method Flux.mergeWith(Publisher): Flux
added: method Flux.metrics(): Flux
added: method Flux.name(String): Flux
added: method Flux.next(): Mono
added: method Flux.ofType(Class): Flux
added: method Flux.onBackpressureBuffer(): Flux
added: method Flux.onBackpressureBuffer(Duration, int, Consumer): Flux
added: method Flux.onBackpressureBuffer(Duration, int, Consumer, Scheduler): Flux
added: method Flux.onBackpressureBuffer(int): Flux
added: method Flux.onBackpressureBuffer(int, BufferOverflowStrategy): Flux
added: method Flux.onBackpressureBuffer(int, Consumer): Flux
added: method Flux.onBackpressureBuffer(int, Consumer, BufferOverflowStrategy): Flux
added: method Flux.onBackpressureDrop(): Flux
added: method Flux.onBackpressureDrop(Consumer): Flux
added: method Flux.onBackpressureError(): Flux
added: method Flux.onBackpressureLatest(): Flux
added: method Flux.onErrorComplete(): Flux
added: method Flux.onErrorComplete(Class): Flux
added: method Flux.onErrorComplete(Predicate): Flux
added: method Flux.onErrorContinue(BiConsumer): Flux
added: method Flux.onErrorContinue(Class, BiConsumer): Flux
added: method Flux.onErrorContinue(Predicate, BiConsumer): Flux
added: method Flux.onErrorMap(Class, Function): Flux
added: method Flux.onErrorMap(Function): Flux
added: method Flux.onErrorMap(Predicate, Function): Flux
added: method Flux.onErrorResume(Class, Function): Flux
added: method Flux.onErrorResume(Function): Flux
added: method Flux.onErrorResume(Predicate, Function): Flux
added: method Flux.onErrorReturn(Class, Object): Flux
added: method Flux.onErrorReturn(Object): Flux
added: method Flux.onErrorReturn(Predicate, Object): Flux
added: method Flux.onErrorStop(): Flux
added: method Flux.onTerminateDetach(): Flux
added: method Flux.or(Publisher): Flux
added: method Flux.parallel(): ParallelFlux
added: method Flux.parallel(int): ParallelFlux
added: method Flux.parallel(int, int): ParallelFlux
added: method Flux.publish(): ConnectableFlux
added: method Flux.publish(Function): Flux
added: method Flux.publish(Function, int): Flux
added: method Flux.publish(int): ConnectableFlux
added: method Flux.publishNext(): Mono
added: method Flux.publishOn(Scheduler): Flux
added: method Flux.publishOn(Scheduler, boolean, int): Flux
added: method Flux.publishOn(Scheduler, int): Flux
added: method Flux.reduce(BiFunction): Mono
added: method Flux.reduce(Object, BiFunction): Mono
added: method Flux.reduceWith(Supplier, BiFunction): Mono
added: method Flux.repeat(): Flux
added: method Flux.repeat(BooleanSupplier): Flux
added: method Flux.repeat(long): Flux
added: method Flux.repeat(long, BooleanSupplier): Flux
added: method Flux.repeatWhen(Function): Flux
added: method Flux.replay(): ConnectableFlux
added: method Flux.replay(Duration): ConnectableFlux
added: method Flux.replay(Duration, Scheduler): ConnectableFlux
added: method Flux.replay(int): ConnectableFlux
added: method Flux.replay(int, Duration): ConnectableFlux
added: method Flux.replay(int, Duration, Scheduler): ConnectableFlux
added: method Flux.retry(): Flux
added: method Flux.retry(long): Flux
added: method Flux.retryWhen(Retry): Flux
added: method Flux.sample(Duration): Flux
added: method Flux.sample(Publisher): Flux
added: method Flux.sampleFirst(Duration): Flux
added: method Flux.sampleFirst(Function): Flux
added: method Flux.sampleTimeout(Function): Flux
added: method Flux.sampleTimeout(Function, int): Flux
added: method Flux.scan(BiFunction): Flux
added: method Flux.scan(Object, BiFunction): Flux
added: method Flux.scanWith(Supplier, BiFunction): Flux
added: method Flux.share(): Flux
added: method Flux.shareNext(): Mono
added: method Flux.single(): Mono
added: method Flux.single(Object): Mono
added: method Flux.singleOrEmpty(): Mono
added: method Flux.skip(Duration): Flux
added: method Flux.skip(Duration, Scheduler): Flux
added: method Flux.skip(long): Flux
added: method Flux.skipLast(int): Flux
added: method Flux.skipUntil(Predicate): Flux
added: method Flux.skipUntilOther(Publisher): Flux
added: method Flux.skipWhile(Predicate): Flux
added: method Flux.sort(): Flux
added: method Flux.sort(Comparator): Flux
added: method Flux.startWith(Iterable): Flux
added: method Flux.startWith(Object[]): Flux
added: method Flux.startWith(Publisher): Flux
added: method Flux.subscribe(): Disposable
added: method Flux.subscribe(Consumer): Disposable
added: method Flux.subscribe(Consumer, Consumer): Disposable
added: method Flux.subscribe(Consumer, Consumer, Runnable): Disposable
added: method Flux.subscribe(Consumer, Consumer, Runnable, Consumer): Disposable
added: method Flux.subscribe(Consumer, Consumer, Runnable, Context): Disposable
added: method Flux.subscribe(CoreSubscriber): void
added: method Flux.subscribe(Subscriber): void
added: method Flux.subscribeOn(Scheduler): Flux
added: method Flux.subscribeOn(Scheduler, boolean): Flux
added: method Flux.subscribeWith(Subscriber): Subscriber
added: method Flux.switchIfEmpty(Publisher): Flux
added: method Flux.switchMap(Function): Flux
added: method Flux.switchMap(Function, int): Flux
added: method Flux.switchOnFirst(BiFunction): Flux
added: method Flux.switchOnFirst(BiFunction, boolean): Flux
added: method Flux.tag(String, String): Flux
added: method Flux.take(Duration): Flux
added: method Flux.take(Duration, Scheduler): Flux
added: method Flux.take(long): Flux
added: method Flux.take(long, boolean): Flux
added: method Flux.takeLast(int): Flux
added: method Flux.takeUntil(Predicate): Flux
added: method Flux.takeUntilOther(Publisher): Flux
added: method Flux.takeWhile(Predicate): Flux
added: method Flux.tap(Function): Flux
added: method Flux.tap(SignalListenerFactory): Flux
added: method Flux.tap(Supplier): Flux
added: method Flux.then(): Mono
added: method Flux.then(Mono): Mono
added: method Flux.thenEmpty(Publisher): Mono
added: method Flux.thenMany(Publisher): Flux
added: method Flux.timed(): Flux
added: method Flux.timed(Scheduler): Flux
added: method Flux.timeout(Duration): Flux
added: method Flux.timeout(Duration, Publisher): Flux
added: method Flux.timeout(Duration, Publisher, Scheduler): Flux
added: method Flux.timeout(Duration, Scheduler): Flux
added: method Flux.timeout(Publisher): Flux
added: method Flux.timeout(Publisher, Function): Flux
added: method Flux.timeout(Publisher, Function, Publisher): Flux
added: method Flux.timestamp(): Flux
added: method Flux.timestamp(Scheduler): Flux
added: method Flux.toIterable(): Iterable
added: method Flux.toIterable(int): Iterable
added: method Flux.toIterable(int, Supplier): Iterable
added: method Flux.toStream(): Stream
added: method Flux.toStream(int): Stream
added: method Flux.toString(): String
added: method Flux.transform(Function): Flux
added: method Flux.transformDeferred(Function): Flux
added: method Flux.transformDeferredContextual(BiFunction): Flux
added: method Flux.window(Duration): Flux
added: method Flux.window(Duration, Duration): Flux
added: method Flux.window(Duration, Duration, Scheduler): Flux
added: method Flux.window(Duration, Scheduler): Flux
added: method Flux.window(Publisher): Flux
added: method Flux.window(int): Flux
added: method Flux.window(int, int): Flux
added: method Flux.windowTimeout(int, Duration): Flux
added: method Flux.windowTimeout(int, Duration, Scheduler): Flux
added: method Flux.windowTimeout(int, Duration, Scheduler, boolean): Flux
added: method Flux.windowTimeout(int, Duration, boolean): Flux
added: method Flux.windowUntil(Predicate): Flux
added: method Flux.windowUntil(Predicate, boolean): Flux
added: method Flux.windowUntil(Predicate, boolean, int): Flux
added: method Flux.windowUntilChanged(): Flux
added: method Flux.windowUntilChanged(Function): Flux
added: method Flux.windowUntilChanged(Function, BiPredicate): Flux
added: method Flux.windowWhen(Publisher, Function): Flux
added: method Flux.windowWhile(Predicate): Flux
added: method Flux.windowWhile(Predicate, int): Flux
added: method Flux.withLatestFrom(Publisher, BiFunction): Flux
added: method Flux.zipWith(Publisher): Flux
added: method Flux.zipWith(Publisher, BiFunction): Flux
added: method Flux.zipWith(Publisher, int): Flux
added: method Flux.zipWith(Publisher, int, BiFunction): Flux
added: method Flux.zipWithIterable(Iterable): Flux
added: method Flux.zipWithIterable(Iterable, BiFunction): Flux
added: method FluxOperator.scanUnsafe(Scannable.Attr): Object
added: method FluxProcessor.currentContext(): Context
added: method FluxProcessor.dispose(): void
added: method FluxProcessor.downstreamCount(): long
added: method FluxProcessor.getBufferSize(): int
added: method FluxProcessor.getError(): Throwable
added: method FluxProcessor.hasCompleted(): boolean
added: method FluxProcessor.hasDownstreams(): boolean
added: method FluxProcessor.hasError(): boolean
added: method FluxProcessor.inners(): Stream
added: method FluxProcessor.isIdentityProcessor(): boolean
added: method FluxProcessor.isSerialized(): boolean
added: method FluxProcessor.isTerminated(): boolean
added: method FluxProcessor.scanUnsafe(Scannable.Attr): Object
added: method FluxProcessor.serialize(): FluxProcessor
added: method FluxProcessor.serializeAlways(): boolean
added: method FluxProcessor.sink(): FluxSink
added: method FluxProcessor.sink(FluxSink.OverflowStrategy): FluxSink
added: method FluxSink.complete(): void
added: method FluxSink.contextView(): ContextView
added: method FluxSink.currentContext(): Context
added: method FluxSink.error(Throwable): void
added: method FluxSink.isCancelled(): boolean
added: method FluxSink.next(Object): FluxSink
added: method FluxSink.onCancel(Disposable): FluxSink
added: method FluxSink.onDispose(Disposable): FluxSink
added: method FluxSink.onRequest(LongConsumer): FluxSink
added: method FluxSink.requestedFromDownstream(): long
added: method GroupedFlux.key(): Object
added: method Mono.and(Publisher): Mono
added: method Mono.as(Function): Object
added: method Mono.block(): Object
added: method Mono.block(Duration): Object
added: method Mono.blockOptional(): Optional
added: method Mono.blockOptional(Duration): Optional
added: method Mono.cache(): Mono
added: method Mono.cache(Duration): Mono
added: method Mono.cache(Duration, Scheduler): Mono
added: method Mono.cache(Function, Function, Supplier): Mono
added: method Mono.cache(Function, Function, Supplier, Scheduler): Mono
added: method Mono.cacheInvalidateIf(Predicate): Mono
added: method Mono.cacheInvalidateWhen(Function): Mono
added: method Mono.cacheInvalidateWhen(Function, Consumer): Mono
added: method Mono.cancelOn(Scheduler): Mono
added: method Mono.cast(Class): Mono
added: method Mono.checkpoint(): Mono
added: method Mono.checkpoint(String): Mono
added: method Mono.checkpoint(String, boolean): Mono
added: method Mono.concatWith(Publisher): Flux
added: method Mono.contextCapture(): Mono
added: method Mono.contextWrite(ContextView): Mono
added: method Mono.contextWrite(Function): Mono
added: method Mono.defaultIfEmpty(Object): Mono
added: method Mono.delayElement(Duration): Mono
added: method Mono.delayElement(Duration, Scheduler): Mono
added: method Mono.delaySubscription(Duration): Mono
added: method Mono.delaySubscription(Duration, Scheduler): Mono
added: method Mono.delaySubscription(Publisher): Mono
added: method Mono.delayUntil(Function): Mono
added: method Mono.dematerialize(): Mono
added: method Mono.doAfterTerminate(Runnable): Mono
added: method Mono.doFinally(Consumer): Mono
added: method Mono.doFirst(Runnable): Mono
added: method Mono.doOnCancel(Runnable): Mono
added: method Mono.doOnDiscard(Class, Consumer): Mono
added: method Mono.doOnEach(Consumer): Mono
added: method Mono.doOnError(Class, Consumer): Mono
added: method Mono.doOnError(Consumer): Mono
added: method Mono.doOnError(Predicate, Consumer): Mono
added: method Mono.doOnNext(Consumer): Mono
added: method Mono.doOnRequest(LongConsumer): Mono
added: method Mono.doOnSubscribe(Consumer): Mono
added: method Mono.doOnSuccess(Consumer): Mono
added: method Mono.doOnTerminate(Runnable): Mono
added: method Mono.elapsed(): Mono
added: method Mono.elapsed(Scheduler): Mono
added: method Mono.expand(Function): Flux
added: method Mono.expand(Function, int): Flux
added: method Mono.expandDeep(Function): Flux
added: method Mono.expandDeep(Function, int): Flux
added: method Mono.filter(Predicate): Mono
added: method Mono.filterWhen(Function): Mono
added: method Mono.flatMap(Function): Mono
added: method Mono.flatMapIterable(Function): Flux
added: method Mono.flatMapMany(Function): Flux
added: method Mono.flatMapMany(Function, Function, Supplier): Flux
added: method Mono.flux(): Flux
added: method Mono.handle(BiConsumer): Mono
added: method Mono.hasElement(): Mono
added: method Mono.hide(): Mono
added: method Mono.ignoreElement(): Mono
added: method Mono.log(): Mono
added: method Mono.log(Logger): Mono
added: method Mono.log(Logger, Level, boolean, SignalType[]): Mono
added: method Mono.log(String): Mono
added: method Mono.log(String, Level, SignalType[]): Mono
added: method Mono.log(String, Level, boolean, SignalType[]): Mono
added: method Mono.map(Function): Mono
added: method Mono.mapNotNull(Function): Mono
added: method Mono.materialize(): Mono
added: method Mono.mergeWith(Publisher): Flux
added: method Mono.metrics(): Mono
added: method Mono.name(String): Mono
added: method Mono.ofType(Class): Mono
added: method Mono.onErrorComplete(): Mono
added: method Mono.onErrorComplete(Class): Mono
added: method Mono.onErrorComplete(Predicate): Mono
added: method Mono.onErrorContinue(BiConsumer): Mono
added: method Mono.onErrorContinue(Class, BiConsumer): Mono
added: method Mono.onErrorContinue(Predicate, BiConsumer): Mono
added: method Mono.onErrorMap(Class, Function): Mono
added: method Mono.onErrorMap(Function): Mono
added: method Mono.onErrorMap(Predicate, Function): Mono
added: method Mono.onErrorResume(Class, Function): Mono
added: method Mono.onErrorResume(Function): Mono
added: method Mono.onErrorResume(Predicate, Function): Mono
added: method Mono.onErrorReturn(Class, Object): Mono
added: method Mono.onErrorReturn(Object): Mono
added: method Mono.onErrorReturn(Predicate, Object): Mono
added: method Mono.onErrorStop(): Mono
added: method Mono.onTerminateDetach(): Mono
added: method Mono.or(Mono): Mono
added: method Mono.publish(Function): Mono
added: method Mono.publishOn(Scheduler): Mono
added: method Mono.repeat(): Flux
added: method Mono.repeat(BooleanSupplier): Flux
added: method Mono.repeat(long): Flux
added: method Mono.repeat(long, BooleanSupplier): Flux
added: method Mono.repeatWhen(Function): Flux
added: method Mono.repeatWhenEmpty(Function): Mono
added: method Mono.repeatWhenEmpty(int, Function): Mono
added: method Mono.retry(): Mono
added: method Mono.retry(long): Mono
added: method Mono.retryWhen(Retry): Mono
added: method Mono.share(): Mono
added: method Mono.single(): Mono
added: method Mono.singleOptional(): Mono
added: method Mono.subscribe(): Disposable
added: method Mono.subscribe(Consumer): Disposable
added: method Mono.subscribe(Consumer, Consumer): Disposable
added: method Mono.subscribe(Consumer, Consumer, Runnable): Disposable
added: method Mono.subscribe(Consumer, Consumer, Runnable, Consumer): Disposable
added: method Mono.subscribe(Consumer, Consumer, Runnable, Context): Disposable
added: method Mono.subscribe(CoreSubscriber): void
added: method Mono.subscribe(Subscriber): void
added: method Mono.subscribeOn(Scheduler): Mono
added: method Mono.subscribeWith(Subscriber): Subscriber
added: method Mono.switchIfEmpty(Mono): Mono
added: method Mono.tag(String, String): Mono
added: method Mono.take(Duration): Mono
added: method Mono.take(Duration, Scheduler): Mono
added: method Mono.takeUntilOther(Publisher): Mono
added: method Mono.tap(Function): Mono
added: method Mono.tap(SignalListenerFactory): Mono
added: method Mono.tap(Supplier): Mono
added: method Mono.then(): Mono
added: method Mono.then(Mono): Mono
added: method Mono.thenEmpty(Publisher): Mono
added: method Mono.thenMany(Publisher): Flux
added: method Mono.thenReturn(Object): Mono
added: method Mono.timed(): Mono
added: method Mono.timed(Scheduler): Mono
added: method Mono.timeout(Duration): Mono
added: method Mono.timeout(Duration, Mono): Mono
added: method Mono.timeout(Duration, Mono, Scheduler): Mono
added: method Mono.timeout(Duration, Scheduler): Mono
added: method Mono.timeout(Publisher): Mono
added: method Mono.timeout(Publisher, Mono): Mono
added: method Mono.timestamp(): Mono
added: method Mono.timestamp(Scheduler): Mono
added: method Mono.toFuture(): CompletableFuture
added: method Mono.toString(): String
added: method Mono.transform(Function): Mono
added: method Mono.transformDeferred(Function): Mono
added: method Mono.transformDeferredContextual(BiFunction): Mono
added: method Mono.zipWhen(Function): Mono
added: method Mono.zipWhen(Function, BiFunction): Mono
added: method Mono.zipWith(Mono): Mono
added: method Mono.zipWith(Mono, BiFunction): Mono
added: method MonoOperator.scanUnsafe(Scannable.Attr): Object
added: method MonoProcessor.block(): Object
added: method MonoProcessor.block(Duration): Object
added: method MonoProcessor.cancel(): void
added: method MonoProcessor.currentContext(): Context
added: method MonoProcessor.dispose(): void
added: method MonoProcessor.downstreamCount(): long
added: method MonoProcessor.getError(): Throwable
added: method MonoProcessor.hasDownstreams(): boolean
added: method MonoProcessor.inners(): Stream
added: method MonoProcessor.isCancelled(): boolean
added: method MonoProcessor.isDisposed(): boolean
added: method MonoProcessor.isError(): boolean
added: method MonoProcessor.isSuccess(): boolean
added: method MonoProcessor.isTerminated(): boolean
added: method MonoProcessor.peek(): Object
added: method MonoProcessor.request(long): void
added: method MonoProcessor.scanUnsafe(Scannable.Attr): Object
added: method MonoSink.contextView(): ContextView
added: method MonoSink.currentContext(): Context
added: method MonoSink.error(Throwable): void
added: method MonoSink.onCancel(Disposable): MonoSink
added: method MonoSink.onDispose(Disposable): MonoSink
added: method MonoSink.onRequest(LongConsumer): MonoSink
added: method MonoSink.success(): void
added: method MonoSink.success(Object): void
added: method Operators.DeferredSubscription.cancel(): void
added: method Operators.DeferredSubscription.isCancelled(): boolean
added: method Operators.DeferredSubscription.request(long): void
added: method Operators.DeferredSubscription.scanUnsafe(Scannable.Attr): Object
added: method Operators.DeferredSubscription.set(Subscription): boolean
added: method Operators.DeferredSubscription.terminate(): void
added: method Operators.MonoSubscriber.actual(): CoreSubscriber
added: method Operators.MonoSubscriber.cancel(): void
added: method Operators.MonoSubscriber.clear(): void
added: method Operators.MonoSubscriber.complete(Object): void
added: method Operators.MonoSubscriber.discard(Object): void
added: method Operators.MonoSubscriber.isCancelled(): boolean
added: method Operators.MonoSubscriber.isEmpty(): boolean
added: method Operators.MonoSubscriber.onComplete(): void
added: method Operators.MonoSubscriber.onError(Throwable): void
added: method Operators.MonoSubscriber.onNext(Object): void
added: method Operators.MonoSubscriber.onSubscribe(Subscription): void
added: method Operators.MonoSubscriber.poll(): Object
added: method Operators.MonoSubscriber.request(long): void
added: method Operators.MonoSubscriber.requestFusion(int): int
added: method Operators.MonoSubscriber.scanUnsafe(Scannable.Attr): Object
added: method Operators.MonoSubscriber.setValue(Object): void
added: method Operators.MonoSubscriber.size(): int
added: method ParallelFlux.as(Function): Object
added: method ParallelFlux.checkpoint(): ParallelFlux
added: method ParallelFlux.checkpoint(String): ParallelFlux
added: method ParallelFlux.checkpoint(String, boolean): ParallelFlux
added: method ParallelFlux.collect(Supplier, BiConsumer): ParallelFlux
added: method ParallelFlux.collectSortedList(Comparator): Mono
added: method ParallelFlux.collectSortedList(Comparator, int): Mono
added: method ParallelFlux.concatMap(Function): ParallelFlux
added: method ParallelFlux.concatMap(Function, int): ParallelFlux
added: method ParallelFlux.concatMapDelayError(Function): ParallelFlux
added: method ParallelFlux.doAfterTerminate(Runnable): ParallelFlux
added: method ParallelFlux.doOnCancel(Runnable): ParallelFlux
added: method ParallelFlux.doOnComplete(Runnable): ParallelFlux
added: method ParallelFlux.doOnEach(Consumer): ParallelFlux
added: method ParallelFlux.doOnError(Consumer): ParallelFlux
added: method ParallelFlux.doOnNext(Consumer): ParallelFlux
added: method ParallelFlux.doOnRequest(LongConsumer): ParallelFlux
added: method ParallelFlux.doOnSubscribe(Consumer): ParallelFlux
added: method ParallelFlux.doOnTerminate(Runnable): ParallelFlux
added: method ParallelFlux.filter(Predicate): ParallelFlux
added: method ParallelFlux.flatMap(Function): ParallelFlux
added: method ParallelFlux.flatMap(Function, boolean): ParallelFlux
added: method ParallelFlux.flatMap(Function, boolean, int): ParallelFlux
added: method ParallelFlux.flatMap(Function, boolean, int, int): ParallelFlux
added: method ParallelFlux.getPrefetch(): int
added: method ParallelFlux.groups(): Flux
added: method ParallelFlux.hide(): ParallelFlux
added: method ParallelFlux.log(): ParallelFlux
added: method ParallelFlux.log(String): ParallelFlux
added: method ParallelFlux.log(String, Level, SignalType[]): ParallelFlux
added: method ParallelFlux.log(String, Level, boolean, SignalType[]): ParallelFlux
added: method ParallelFlux.map(Function): ParallelFlux
added: method ParallelFlux.name(String): ParallelFlux
added: method ParallelFlux.ordered(Comparator): Flux
added: method ParallelFlux.ordered(Comparator, int): Flux
added: method ParallelFlux.parallelism(): int
added: method ParallelFlux.reduce(BiFunction): Mono
added: method ParallelFlux.reduce(Supplier, BiFunction): ParallelFlux
added: method ParallelFlux.runOn(Scheduler): ParallelFlux
added: method ParallelFlux.runOn(Scheduler, int): ParallelFlux
added: method ParallelFlux.sequential(): Flux
added: method ParallelFlux.sequential(int): Flux
added: method ParallelFlux.sorted(Comparator): Flux
added: method ParallelFlux.sorted(Comparator, int): Flux
added: method ParallelFlux.subscribe(): Disposable
added: method ParallelFlux.subscribe(Consumer): Disposable
added: method ParallelFlux.subscribe(Consumer, Consumer): Disposable
added: method ParallelFlux.subscribe(Consumer, Consumer, Runnable): Disposable
added: method ParallelFlux.subscribe(Consumer, Consumer, Runnable, Consumer): Disposable
added: method ParallelFlux.subscribe(Consumer, Consumer, Runnable, Context): Disposable
added: method ParallelFlux.subscribe(CoreSubscriber): void
added: method ParallelFlux.subscribe(CoreSubscriber[]): void
added: method ParallelFlux.subscribe(Subscriber): void
added: method ParallelFlux.tag(String, String): ParallelFlux
added: method ParallelFlux.then(): Mono
added: method ParallelFlux.toString(): String
added: method ParallelFlux.transform(Function): ParallelFlux
added: method ParallelFlux.transformGroups(Function): ParallelFlux
added: method ParallelFlux.validate(Subscriber[]): boolean
added: method ReplayProcessor.asFlux(): Flux
added: method ReplayProcessor.currentContext(): Context
added: method ReplayProcessor.currentSubscriberCount(): int
added: method ReplayProcessor.downstreamCount(): long
added: method ReplayProcessor.getError(): Throwable
added: method ReplayProcessor.getPrefetch(): int
added: method ReplayProcessor.inners(): Stream
added: method ReplayProcessor.isIdentityProcessor(): boolean
added: method ReplayProcessor.isTerminated(): boolean
added: method ReplayProcessor.onComplete(): void
added: method ReplayProcessor.onError(Throwable): void
added: method ReplayProcessor.onNext(Object): void
added: method ReplayProcessor.onSubscribe(Subscription): void
added: method ReplayProcessor.scanUnsafe(Scannable.Attr): Object
added: method ReplayProcessor.subscribe(CoreSubscriber): void
added: method ReplayProcessor.tryEmitComplete(): Sinks.EmitResult
added: method ReplayProcessor.tryEmitError(Throwable): Sinks.EmitResult
added: method ReplayProcessor.tryEmitNext(Object): Sinks.EmitResult
added: method Signal.accept(Subscriber): void
added: method Signal.get(): Object
added: method Signal.getContextView(): ContextView
added: method Signal.getSubscription(): Subscription
added: method Signal.getThrowable(): Throwable
added: method Signal.getType(): SignalType
added: method Signal.hasError(): boolean
added: method Signal.hasValue(): boolean
added: method Signal.isOnComplete(): boolean
added: method Signal.isOnError(): boolean
added: method Signal.isOnNext(): boolean
added: method Signal.isOnSubscribe(): boolean
added: method SignalType.toString(): String
added: method SinkOneSerialized.tryEmitValue(Object): Sinks.EmitResult
added: method Sinks.EmissionException.getReason(): Sinks.EmitResult
added: method Sinks.EmitFailureHandler.onEmitFailure(SignalType, Sinks.EmitResult): boolean
added: method Sinks.EmitResult.isFailure(): boolean
added: method Sinks.EmitResult.isSuccess(): boolean
added: method Sinks.EmitResult.orThrow(): void
added: method Sinks.EmitResult.orThrowWithCause(Throwable): void
added: method Sinks.Empty.asMono(): Mono
added: method Sinks.Empty.currentSubscriberCount(): int
added: method Sinks.Empty.emitEmpty(Sinks.EmitFailureHandler): void
added: method Sinks.Empty.emitError(Throwable, Sinks.EmitFailureHandler): void
added: method Sinks.Empty.tryEmitEmpty(): Sinks.EmitResult
added: method Sinks.Empty.tryEmitError(Throwable): Sinks.EmitResult
added: method Sinks.Many.asFlux(): Flux
added: method Sinks.Many.currentSubscriberCount(): int
added: method Sinks.Many.emitComplete(Sinks.EmitFailureHandler): void
added: method Sinks.Many.emitError(Throwable, Sinks.EmitFailureHandler): void
added: method Sinks.Many.emitNext(Object, Sinks.EmitFailureHandler): void
added: method Sinks.Many.tryEmitComplete(): Sinks.EmitResult
added: method Sinks.Many.tryEmitError(Throwable): Sinks.EmitResult
added: method Sinks.Many.tryEmitNext(Object): Sinks.EmitResult
added: method Sinks.ManySpec.multicast(): Sinks.MulticastSpec
added: method Sinks.ManySpec.replay(): Sinks.MulticastReplaySpec
added: method Sinks.ManySpec.unicast(): Sinks.UnicastSpec
added: method Sinks.ManyWithUpstream.subscribeTo(Publisher): Disposable
added: method Sinks.ManyWithUpstreamUnsafeSpec.multicastOnBackpressureBuffer(): Sinks.ManyWithUpstream
added: method Sinks.ManyWithUpstreamUnsafeSpec.multicastOnBackpressureBuffer(int, boolean): Sinks.ManyWithUpstream
added: method Sinks.MulticastReplaySpec.all(): Sinks.Many
added: method Sinks.MulticastReplaySpec.all(int): Sinks.Many
added: method Sinks.MulticastReplaySpec.latest(): Sinks.Many
added: method Sinks.MulticastReplaySpec.latestOrDefault(Object): Sinks.Many
added: method Sinks.MulticastReplaySpec.limit(Duration): Sinks.Many
added: method Sinks.MulticastReplaySpec.limit(Duration, Scheduler): Sinks.Many
added: method Sinks.MulticastReplaySpec.limit(int): Sinks.Many
added: method Sinks.MulticastReplaySpec.limit(int, Duration): Sinks.Many
added: method Sinks.MulticastReplaySpec.limit(int, Duration, Scheduler): Sinks.Many
added: method Sinks.MulticastSpec.directAllOrNothing(): Sinks.Many
added: method Sinks.MulticastSpec.directBestEffort(): Sinks.Many
added: method Sinks.MulticastSpec.onBackpressureBuffer(): Sinks.Many
added: method Sinks.MulticastSpec.onBackpressureBuffer(int): Sinks.Many
added: method Sinks.MulticastSpec.onBackpressureBuffer(int, boolean): Sinks.Many
added: method Sinks.One.emitValue(Object, Sinks.EmitFailureHandler): void
added: method Sinks.One.tryEmitValue(Object): Sinks.EmitResult
added: method Sinks.RootSpec.empty(): Sinks.Empty
added: method Sinks.RootSpec.many(): Sinks.ManySpec
added: method Sinks.RootSpec.manyWithUpstream(): Sinks.ManyWithUpstreamUnsafeSpec
added: method Sinks.RootSpec.one(): Sinks.One
added: method Sinks.UnicastSpec.onBackpressureBuffer(): Sinks.Many
added: method Sinks.UnicastSpec.onBackpressureBuffer(Queue): Sinks.Many
added: method Sinks.UnicastSpec.onBackpressureBuffer(Queue, Disposable): Sinks.Many
added: method Sinks.UnicastSpec.onBackpressureError(): Sinks.Many
added: method SynchronousSink.complete(): void
added: method SynchronousSink.contextView(): ContextView
added: method SynchronousSink.currentContext(): Context
added: method SynchronousSink.error(Throwable): void
added: method SynchronousSink.next(Object): void
added: method Timed.elapsed(): Duration
added: method Timed.elapsedSinceSubscription(): Duration
added: method Timed.get(): Object
added: method Timed.timestamp(): Instant
added: method UnicastProcessor.actual(): CoreSubscriber
added: method UnicastProcessor.asFlux(): Flux
added: method UnicastProcessor.cancel(): void
added: method UnicastProcessor.clear(): void
added: method UnicastProcessor.currentContext(): Context
added: method UnicastProcessor.currentSubscriberCount(): int
added: method UnicastProcessor.downstreamCount(): long
added: method UnicastProcessor.emitNext(Object, Sinks.EmitFailureHandler): void
added: method UnicastProcessor.getBufferSize(): int
added: method UnicastProcessor.getError(): Throwable
added: method UnicastProcessor.getPrefetch(): int
added: method UnicastProcessor.hasDownstreams(): boolean
added: method UnicastProcessor.inners(): Stream
added: method UnicastProcessor.isDisposed(): boolean
added: method UnicastProcessor.isEmpty(): boolean
added: method UnicastProcessor.isIdentityProcessor(): boolean
added: method UnicastProcessor.isTerminated(): boolean
added: method UnicastProcessor.onComplete(): void
added: method UnicastProcessor.onError(Throwable): void
added: method UnicastProcessor.onNext(Object): void
added: method UnicastProcessor.onSubscribe(Subscription): void
added: method UnicastProcessor.poll(): Object
added: method UnicastProcessor.request(long): void
added: method UnicastProcessor.requestFusion(int): int
added: method UnicastProcessor.scanUnsafe(Scannable.Attr): Object
added: method UnicastProcessor.size(): int
added: method UnicastProcessor.subscribe(CoreSubscriber): void
added: method UnicastProcessor.tryEmitComplete(): Sinks.EmitResult
added: method UnicastProcessor.tryEmitError(Throwable): Sinks.EmitResult
added: method UnicastProcessor.tryEmitNext(Object): Sinks.EmitResult
added: static class Operators.DeferredSubscription implements Subscription, Scannable
added: static class Operators.MonoSubscriber implements InnerOperator, Fuseable, Fuseable.QueueSubscription
added: static field BufferOverflowStrategy.DROP_LATEST: BufferOverflowStrategy
added: static field BufferOverflowStrategy.DROP_OLDEST: BufferOverflowStrategy
added: static field BufferOverflowStrategy.ERROR: BufferOverflowStrategy
added: static field FluxSink.OverflowStrategy.BUFFER: FluxSink.OverflowStrategy
added: static field FluxSink.OverflowStrategy.DROP: FluxSink.OverflowStrategy
added: static field FluxSink.OverflowStrategy.ERROR: FluxSink.OverflowStrategy
added: static field FluxSink.OverflowStrategy.IGNORE: FluxSink.OverflowStrategy
added: static field FluxSink.OverflowStrategy.LATEST: FluxSink.OverflowStrategy
added: static field SignalType.AFTER_TERMINATE: SignalType
added: static field SignalType.CANCEL: SignalType
added: static field SignalType.CURRENT_CONTEXT: SignalType
added: static field SignalType.ON_COMPLETE: SignalType
added: static field SignalType.ON_CONTEXT: SignalType
added: static field SignalType.ON_ERROR: SignalType
added: static field SignalType.ON_NEXT: SignalType
added: static field SignalType.ON_SUBSCRIBE: SignalType
added: static field SignalType.REQUEST: SignalType
added: static field SignalType.SUBSCRIBE: SignalType
added: static field Sinks.EmitFailureHandler.FAIL_FAST: Sinks.EmitFailureHandler
added: static field Sinks.EmitResult.FAIL_CANCELLED: Sinks.EmitResult
added: static field Sinks.EmitResult.FAIL_NON_SERIALIZED: Sinks.EmitResult
added: static field Sinks.EmitResult.FAIL_OVERFLOW: Sinks.EmitResult
added: static field Sinks.EmitResult.FAIL_TERMINATED: Sinks.EmitResult
added: static field Sinks.EmitResult.FAIL_ZERO_SUBSCRIBER: Sinks.EmitResult
added: static field Sinks.EmitResult.OK: Sinks.EmitResult
added: static final class Sinks.EmissionException extends IllegalStateException
added: static method BufferOverflowStrategy.valueOf(String): BufferOverflowStrategy
added: static method BufferOverflowStrategy.values(): BufferOverflowStrategy[]
added: static method DirectProcessor.create(): DirectProcessor
added: static method EmitterProcessor.create(): EmitterProcessor
added: static method EmitterProcessor.create(boolean): EmitterProcessor
added: static method EmitterProcessor.create(int): EmitterProcessor
added: static method EmitterProcessor.create(int, boolean): EmitterProcessor
added: static method Flux.combineLatest(Function, Publisher[]): Flux
added: static method Flux.combineLatest(Function, int, Publisher[]): Flux
added: static method Flux.combineLatest(Iterable, Function): Flux
added: static method Flux.combineLatest(Iterable, int, Function): Flux
added: static method Flux.combineLatest(Publisher, Publisher, BiFunction): Flux
added: static method Flux.combineLatest(Publisher, Publisher, Publisher, Function): Flux
added: static method Flux.combineLatest(Publisher, Publisher, Publisher, Publisher, Function): Flux
added: static method Flux.combineLatest(Publisher, Publisher, Publisher, Publisher, Publisher, Function): Flux
added: static method Flux.combineLatest(Publisher, Publisher, Publisher, Publisher, Publisher, Publisher, Function): Flux
added: static method Flux.concat(Iterable): Flux
added: static method Flux.concat(Publisher): Flux
added: static method Flux.concat(Publisher, int): Flux
added: static method Flux.concat(Publisher[]): Flux
added: static method Flux.concatDelayError(Publisher): Flux
added: static method Flux.concatDelayError(Publisher, boolean, int): Flux
added: static method Flux.concatDelayError(Publisher, int): Flux
added: static method Flux.concatDelayError(Publisher[]): Flux
added: static method Flux.create(Consumer): Flux
added: static method Flux.create(Consumer, FluxSink.OverflowStrategy): Flux
added: static method Flux.defer(Supplier): Flux
added: static method Flux.deferContextual(Function): Flux
added: static method Flux.empty(): Flux
added: static method Flux.error(Supplier): Flux
added: static method Flux.error(Throwable): Flux
added: static method Flux.error(Throwable, boolean): Flux
added: static method Flux.first(Iterable): Flux
added: static method Flux.first(Publisher[]): Flux
added: static method Flux.firstWithSignal(Iterable): Flux
added: static method Flux.firstWithSignal(Publisher[]): Flux
added: static method Flux.firstWithValue(Iterable): Flux
added: static method Flux.firstWithValue(Publisher, Publisher[]): Flux
added: static method Flux.from(Publisher): Flux
added: static method Flux.fromArray(Object[]): Flux
added: static method Flux.fromIterable(Iterable): Flux
added: static method Flux.fromStream(Stream): Flux
added: static method Flux.fromStream(Supplier): Flux
added: static method Flux.generate(Callable, BiFunction): Flux
added: static method Flux.generate(Callable, BiFunction, Consumer): Flux
added: static method Flux.generate(Consumer): Flux
added: static method Flux.interval(Duration): Flux
added: static method Flux.interval(Duration, Duration): Flux
added: static method Flux.interval(Duration, Duration, Scheduler): Flux
added: static method Flux.interval(Duration, Scheduler): Flux
added: static method Flux.just(Object): Flux
added: static method Flux.just(Object[]): Flux
added: static method Flux.merge(Iterable): Flux
added: static method Flux.merge(Publisher): Flux
added: static method Flux.merge(Publisher, int): Flux
added: static method Flux.merge(Publisher, int, int): Flux
added: static method Flux.merge(Publisher[]): Flux
added: static method Flux.merge(int, Publisher[]): Flux
added: static method Flux.mergeComparing(Comparator, Publisher[]): Flux
added: static method Flux.mergeComparing(Publisher[]): Flux
added: static method Flux.mergeComparing(int, Comparator, Publisher[]): Flux
added: static method Flux.mergeComparingDelayError(int, Comparator, Publisher[]): Flux
added: static method Flux.mergeDelayError(int, Publisher[]): Flux
added: static method Flux.mergeOrdered(Comparator, Publisher[]): Flux
added: static method Flux.mergeOrdered(Publisher[]): Flux
added: static method Flux.mergeOrdered(int, Comparator, Publisher[]): Flux
added: static method Flux.mergePriority(Comparator, Publisher[]): Flux
added: static method Flux.mergePriority(Publisher[]): Flux
added: static method Flux.mergePriority(int, Comparator, Publisher[]): Flux
added: static method Flux.mergePriorityDelayError(int, Comparator, Publisher[]): Flux
added: static method Flux.mergeSequential(Iterable): Flux
added: static method Flux.mergeSequential(Iterable, int, int): Flux
added: static method Flux.mergeSequential(Publisher): Flux
added: static method Flux.mergeSequential(Publisher, int, int): Flux
added: static method Flux.mergeSequential(Publisher[]): Flux
added: static method Flux.mergeSequential(int, Publisher[]): Flux
added: static method Flux.mergeSequentialDelayError(Iterable, int, int): Flux
added: static method Flux.mergeSequentialDelayError(Publisher, int, int): Flux
added: static method Flux.mergeSequentialDelayError(int, Publisher[]): Flux
added: static method Flux.never(): Flux
added: static method Flux.onAssembly(ConnectableFlux): ConnectableFlux
added: static method Flux.onAssembly(Flux): Flux
added: static method Flux.push(Consumer): Flux
added: static method Flux.push(Consumer, FluxSink.OverflowStrategy): Flux
added: static method Flux.range(int, int): Flux
added: static method Flux.switchOnNext(Publisher): Flux
added: static method Flux.switchOnNext(Publisher, int): Flux
added: static method Flux.using(Callable, Function): Flux
added: static method Flux.using(Callable, Function, Consumer): Flux
added: static method Flux.using(Callable, Function, Consumer, boolean): Flux
added: static method Flux.using(Callable, Function, boolean): Flux
added: static method Flux.usingWhen(Publisher, Function, Function): Flux
added: static method Flux.usingWhen(Publisher, Function, Function, BiFunction, Function): Flux
added: static method Flux.zip(Function, Publisher[]): Flux
added: static method Flux.zip(Function, int, Publisher[]): Flux
added: static method Flux.zip(Iterable, Function): Flux
added: static method Flux.zip(Iterable, int, Function): Flux
added: static method Flux.zip(Publisher, Function): Flux
added: static method Flux.zip(Publisher, Publisher): Flux
added: static method Flux.zip(Publisher, Publisher, BiFunction): Flux
added: static method Flux.zip(Publisher, Publisher, Publisher): Flux
added: static method Flux.zip(Publisher, Publisher, Publisher, Publisher): Flux
added: static method Flux.zip(Publisher, Publisher, Publisher, Publisher, Publisher): Flux
added: static method Flux.zip(Publisher, Publisher, Publisher, Publisher, Publisher, Publisher): Flux
added: static method Flux.zip(Publisher, Publisher, Publisher, Publisher, Publisher, Publisher, Publisher): Flux
added: static method Flux.zip(Publisher, Publisher, Publisher, Publisher, Publisher, Publisher, Publisher, Publisher): Flux
added: static method FluxProcessor.switchOnNext(): FluxProcessor
added: static method FluxProcessor.wrap(Subscriber, Publisher): FluxProcessor
added: static method FluxSink.OverflowStrategy.valueOf(String): FluxSink.OverflowStrategy
added: static method FluxSink.OverflowStrategy.values(): FluxSink.OverflowStrategy[]
added: static method Hooks.addCallSiteInfo(Publisher, String): Publisher
added: static method Hooks.addQueueWrapper(String, Function): void
added: static method Hooks.addReturnInfo(Publisher, String): Publisher
added: static method Hooks.convertToFluxBypassingHooks(Publisher): Flux
added: static method Hooks.convertToMonoBypassingHooks(Publisher, boolean): Mono
added: static method Hooks.disableAutomaticContextPropagation(): void
added: static method Hooks.disableContextLossTracking(): void
added: static method Hooks.enableAutomaticContextPropagation(): void
added: static method Hooks.enableContextLossTracking(): void
added: static method Hooks.isAutomaticContextPropagationEnabled(): boolean
added: static method Hooks.onEachOperator(Function): void
added: static method Hooks.onEachOperator(String, Function): void
added: static method Hooks.onErrorDropped(Consumer): void
added: static method Hooks.onLastOperator(Function): void
added: static method Hooks.onLastOperator(String, Function): void
added: static method Hooks.onNextDropped(Consumer): void
added: static method Hooks.onNextDroppedFail(): void
added: static method Hooks.onNextError(BiFunction): void
added: static method Hooks.onOperatorDebug(): void
added: static method Hooks.onOperatorError(BiFunction): void
added: static method Hooks.onOperatorError(String, BiFunction): void
added: static method Hooks.removeQueueWrapper(String): void
added: static method Hooks.removeQueueWrappers(): void
added: static method Hooks.resetOnEachOperator(): void
added: static method Hooks.resetOnEachOperator(String): void
added: static method Hooks.resetOnErrorDropped(): void
added: static method Hooks.resetOnLastOperator(): void
added: static method Hooks.resetOnLastOperator(String): void
added: static method Hooks.resetOnNextDropped(): void
added: static method Hooks.resetOnNextError(): void
added: static method Hooks.resetOnOperatorDebug(): void
added: static method Hooks.resetOnOperatorError(): void
added: static method Hooks.resetOnOperatorError(String): void
added: static method Hooks.wrapQueue(Queue): Queue
added: static method Mono.create(Consumer): Mono
added: static method Mono.defer(Supplier): Mono
added: static method Mono.deferContextual(Function): Mono
added: static method Mono.delay(Duration): Mono
added: static method Mono.delay(Duration, Scheduler): Mono
added: static method Mono.empty(): Mono
added: static method Mono.error(Supplier): Mono
added: static method Mono.error(Throwable): Mono
added: static method Mono.first(Iterable): Mono
added: static method Mono.first(Mono[]): Mono
added: static method Mono.firstWithSignal(Iterable): Mono
added: static method Mono.firstWithSignal(Mono[]): Mono
added: static method Mono.firstWithValue(Iterable): Mono
added: static method Mono.firstWithValue(Mono, Mono[]): Mono
added: static method Mono.from(Publisher): Mono
added: static method Mono.fromCallable(Callable): Mono
added: static method Mono.fromCompletionStage(CompletionStage): Mono
added: static method Mono.fromCompletionStage(Supplier): Mono
added: static method Mono.fromDirect(Publisher): Mono
added: static method Mono.fromFuture(CompletableFuture): Mono
added: static method Mono.fromFuture(CompletableFuture, boolean): Mono
added: static method Mono.fromFuture(Supplier): Mono
added: static method Mono.fromFuture(Supplier, boolean): Mono
added: static method Mono.fromRunnable(Runnable): Mono
added: static method Mono.fromSupplier(Supplier): Mono
added: static method Mono.ignoreElements(Publisher): Mono
added: static method Mono.just(Object): Mono
added: static method Mono.justOrEmpty(Object): Mono
added: static method Mono.justOrEmpty(Optional): Mono
added: static method Mono.never(): Mono
added: static method Mono.onAssembly(Mono): Mono
added: static method Mono.sequenceEqual(Publisher, Publisher): Mono
added: static method Mono.sequenceEqual(Publisher, Publisher, BiPredicate): Mono
added: static method Mono.sequenceEqual(Publisher, Publisher, BiPredicate, int): Mono
added: static method Mono.using(Callable, Function): Mono
added: static method Mono.using(Callable, Function, Consumer): Mono
added: static method Mono.using(Callable, Function, Consumer, boolean): Mono
added: static method Mono.using(Callable, Function, boolean): Mono
added: static method Mono.usingWhen(Publisher, Function, Function): Mono
added: static method Mono.usingWhen(Publisher, Function, Function, BiFunction, Function): Mono
added: static method Mono.when(Iterable): Mono
added: static method Mono.when(Publisher[]): Mono
added: static method Mono.whenDelayError(Iterable): Mono
added: static method Mono.whenDelayError(Publisher[]): Mono
added: static method Mono.zip(Function, Mono[]): Mono
added: static method Mono.zip(Iterable, Function): Mono
added: static method Mono.zip(Mono, Mono): Mono
added: static method Mono.zip(Mono, Mono, BiFunction): Mono
added: static method Mono.zip(Mono, Mono, Mono): Mono
added: static method Mono.zip(Mono, Mono, Mono, Mono): Mono
added: static method Mono.zip(Mono, Mono, Mono, Mono, Mono): Mono
added: static method Mono.zip(Mono, Mono, Mono, Mono, Mono, Mono): Mono
added: static method Mono.zip(Mono, Mono, Mono, Mono, Mono, Mono, Mono): Mono
added: static method Mono.zip(Mono, Mono, Mono, Mono, Mono, Mono, Mono, Mono): Mono
added: static method Mono.zipDelayError(Function, Mono[]): Mono
added: static method Mono.zipDelayError(Iterable, Function): Mono
added: static method Mono.zipDelayError(Mono, Mono): Mono
added: static method Mono.zipDelayError(Mono, Mono, Mono): Mono
added: static method Mono.zipDelayError(Mono, Mono, Mono, Mono): Mono
added: static method Mono.zipDelayError(Mono, Mono, Mono, Mono, Mono): Mono
added: static method Mono.zipDelayError(Mono, Mono, Mono, Mono, Mono, Mono): Mono
added: static method Mono.zipDelayError(Mono, Mono, Mono, Mono, Mono, Mono, Mono): Mono
added: static method Mono.zipDelayError(Mono, Mono, Mono, Mono, Mono, Mono, Mono, Mono): Mono
added: static method MonoProcessor.create(): MonoProcessor
added: static method Operators.addCap(AtomicLongFieldUpdater, Object, long): long
added: static method Operators.addCap(long, long): long
added: static method Operators.as(Subscription): Fuseable.QueueSubscription
added: static method Operators.canAppearAfterOnSubscribe(Subscription): boolean
added: static method Operators.cancelledSubscription(): Subscription
added: static method Operators.complete(Subscriber): void
added: static method Operators.drainSubscriber(): CoreSubscriber
added: static method Operators.emptySubscriber(): CoreSubscriber
added: static method Operators.emptySubscription(): Subscription
added: static method Operators.enableOnDiscard(Context, Consumer): Context
added: static method Operators.error(Subscriber, Throwable): void
added: static method Operators.lift(BiFunction): Function
added: static method Operators.lift(Predicate, BiFunction): Function
added: static method Operators.liftPublisher(BiFunction): Function
added: static method Operators.liftPublisher(Predicate, BiFunction): Function
added: static method Operators.multiplyCap(long, long): long
added: static method Operators.onDiscard(Object, Context): void
added: static method Operators.onDiscardMultiple(Collection, Context): void
added: static method Operators.onDiscardMultiple(Iterator, boolean, Context): void
added: static method Operators.onDiscardMultiple(Spliterator, boolean, Context): void
added: static method Operators.onDiscardMultiple(Stream, Context): void
added: static method Operators.onDiscardQueueWithClear(Queue, Context, Function): void
added: static method Operators.onErrorDropped(Throwable, Context): void
added: static method Operators.onLastAssembly(CorePublisher): CorePublisher
added: static method Operators.onNextDropped(Object, Context): void
added: static method Operators.onNextError(Object, Throwable, Context): Throwable
added: static method Operators.onNextError(Object, Throwable, Context, Subscription): Throwable
added: static method Operators.onNextErrorFunction(Context): BiFunction
added: static method Operators.onNextInnerError(Throwable, Context, Subscription): Throwable
added: static method Operators.onNextPollError(Object, Throwable, Context): RuntimeException
added: static method Operators.onOperatorError(Subscription, Throwable, Context): Throwable
added: static method Operators.onOperatorError(Subscription, Throwable, Object, Context): Throwable
added: static method Operators.onOperatorError(Throwable, Context): Throwable
added: static method Operators.onRejectedExecution(Throwable, Context): RuntimeException
added: static method Operators.onRejectedExecution(Throwable, Subscription, Throwable, Object, Context): RuntimeException
added: static method Operators.produced(AtomicLongFieldUpdater, Object, long): long
added: static method Operators.replace(AtomicReferenceFieldUpdater, Object, Subscription): boolean
added: static method Operators.reportBadRequest(long): void
added: static method Operators.reportMoreProduced(): void
added: static method Operators.reportSubscriptionSet(): void
added: static method Operators.reportThrowInSubscribe(CoreSubscriber, Throwable): void
added: static method Operators.scalarSubscription(CoreSubscriber, Object): Subscription
added: static method Operators.scalarSubscription(CoreSubscriber, Object, String): Subscription
added: static method Operators.serialize(CoreSubscriber): CoreSubscriber
added: static method Operators.set(AtomicReferenceFieldUpdater, Object, Subscription): boolean
added: static method Operators.setOnce(AtomicReferenceFieldUpdater, Object, Subscription): boolean
added: static method Operators.subOrZero(long, long): long
added: static method Operators.terminate(AtomicReferenceFieldUpdater, Object): boolean
added: static method Operators.toConditionalSubscriber(CoreSubscriber): Fuseable.ConditionalSubscriber
added: static method Operators.toCoreSubscriber(Subscriber): CoreSubscriber
added: static method Operators.toFluxOrMono(Publisher): CorePublisher
added: static method Operators.toFluxOrMono(Publisher[]): void
added: static method Operators.validate(Subscription, Subscription): boolean
added: static method Operators.validate(long): boolean
added: static method ParallelFlux.from(Publisher): ParallelFlux
added: static method ParallelFlux.from(Publisher, int): ParallelFlux
added: static method ParallelFlux.from(Publisher, int, int, Supplier): ParallelFlux
added: static method ParallelFlux.from(Publisher[]): ParallelFlux
added: static method ParallelFlux.onAssembly(ParallelFlux): ParallelFlux
added: static method ReplayProcessor.cacheLast(): ReplayProcessor
added: static method ReplayProcessor.cacheLastOrDefault(Object): ReplayProcessor
added: static method ReplayProcessor.create(): ReplayProcessor
added: static method ReplayProcessor.create(int): ReplayProcessor
added: static method ReplayProcessor.create(int, boolean): ReplayProcessor
added: static method ReplayProcessor.createSizeAndTimeout(int, Duration): ReplayProcessor
added: static method ReplayProcessor.createSizeAndTimeout(int, Duration, Scheduler): ReplayProcessor
added: static method ReplayProcessor.createTimeout(Duration): ReplayProcessor
added: static method ReplayProcessor.createTimeout(Duration, Scheduler): ReplayProcessor
added: static method Signal.complete(): Signal
added: static method Signal.complete(Context): Signal
added: static method Signal.error(Throwable): Signal
added: static method Signal.error(Throwable, Context): Signal
added: static method Signal.isComplete(Object): boolean
added: static method Signal.isError(Object): boolean
added: static method Signal.next(Object): Signal
added: static method Signal.next(Object, Context): Signal
added: static method Signal.subscribe(Subscription): Signal
added: static method Signal.subscribe(Subscription, Context): Signal
added: static method SignalType.valueOf(String): SignalType
added: static method SignalType.values(): SignalType[]
added: static method Sinks.EmitFailureHandler.busyLooping(Duration): Sinks.EmitFailureHandler
added: static method Sinks.EmitResult.valueOf(String): Sinks.EmitResult
added: static method Sinks.EmitResult.values(): Sinks.EmitResult[]
added: static method Sinks.empty(): Sinks.Empty
added: static method Sinks.many(): Sinks.ManySpec
added: static method Sinks.one(): Sinks.One
added: static method Sinks.unsafe(): Sinks.RootSpec
added: static method UnicastProcessor.create(): UnicastProcessor
added: static method UnicastProcessor.create(Queue): UnicastProcessor
added: static method UnicastProcessor.create(Queue, Consumer, Disposable): UnicastProcessor
added: static method UnicastProcessor.create(Queue, Disposable): UnicastProcessor

removed: ctor CompletableBlockingQueue(int)
removed: ctor CompletableLinkedQueue()
removed: final class CompletableBlockingQueue extends ArrayBlockingQueue implements CompletableQueue
removed: final class CompletableLinkedQueue extends LinkedTransferQueue implements CompletableQueue
removed: interface CompletableQueue extends Queue
removed: method CompletableBlockingQueue.complete(): void
removed: method CompletableBlockingQueue.isComplete(): boolean
removed: method CompletableBlockingQueue.poll(): Object
removed: method CompletableBlockingQueue.poll(long, TimeUnit): Object
removed: method CompletableBlockingQueue.take(): Object
removed: method CompletableLinkedQueue.complete(): void
removed: method CompletableLinkedQueue.isComplete(): boolean
removed: method CompletableQueue.complete(): void
removed: method CompletableQueue.isComplete(): boolean

removed: abstract class MpscLinkedQueueNode
removed: ctor MpscLinkedQueueNode()
removed: final class MpscLinkedQueue extends MpscLinkedQueueTailRef implements Queue
removed: method MpscLinkedQueue.add(Object): boolean
removed: method MpscLinkedQueue.addAll(Collection): boolean
removed: method MpscLinkedQueue.clear(): void
removed: method MpscLinkedQueue.contains(Object): boolean
removed: method MpscLinkedQueue.containsAll(Collection): boolean
removed: method MpscLinkedQueue.element(): Object
removed: method MpscLinkedQueue.isEmpty(): boolean
removed: method MpscLinkedQueue.iterator(): Iterator
removed: method MpscLinkedQueue.offer(Object): boolean
removed: method MpscLinkedQueue.peek(): Object
removed: method MpscLinkedQueue.poll(): Object
removed: method MpscLinkedQueue.remove(): Object
removed: method MpscLinkedQueue.remove(Object): boolean
removed: method MpscLinkedQueue.removeAll(Collection): boolean
removed: method MpscLinkedQueue.retainAll(Collection): boolean
removed: method MpscLinkedQueue.size(): int
removed: method MpscLinkedQueue.toArray(): Object[]
removed: method MpscLinkedQueue.toArray(Object[]): Object[]
removed: method MpscLinkedQueueNode.clearMaybe(): Object
removed: method MpscLinkedQueueNode.value(): Object
removed: static method MpscLinkedQueue.create(): Queue

removed: class SerializedSubscriber implements Subscription, Subscriber, NonBlocking
removed: class SubscriberBarrier implements Subscriber, Subscription, NonBlocking
removed: class SubscriberWithContext implements Subscriber
removed: class SubscriptionWithContext implements Subscription
removed: ctor PublisherFactory()
removed: ctor SubscriberBarrier(Subscriber)
removed: ctor SubscriberFactory()
removed: ctor SubscriberWithContext(Object, Subscriber)
removed: ctor SubscriptionWithContext(Object, Subscription)
removed: field SubscriberBarrier.subscriber: Subscriber
removed: field SubscriberWithContext.context: Object
removed: field SubscriberWithContext.subscriber: Subscriber
removed: field SubscriptionWithContext.context: Object
removed: field SubscriptionWithContext.subscription: Subscription
removed: final class PublisherFactory
removed: final class SubscriberFactory
removed: method PublisherFactory.PrematureCompleteException.fillInStackTrace(): Throwable
removed: method SerializedSubscriber.cancel(): void
removed: method SerializedSubscriber.delegate(): Subscriber
removed: method SerializedSubscriber.getCapacity(): long
removed: method SerializedSubscriber.isReactivePull(Dispatcher, long): boolean
removed: method SerializedSubscriber.onComplete(): void
removed: method SerializedSubscriber.onError(Throwable): void
removed: method SerializedSubscriber.onNext(Object): void
removed: method SerializedSubscriber.onSubscribe(Subscription): void
removed: method SerializedSubscriber.request(long): void
removed: method SerializedSubscriber.toString(): String
removed: method SubscriberBarrier.cancel(): void
removed: method SubscriberBarrier.doCancel(): void
removed: method SubscriberBarrier.doComplete(): void
removed: method SubscriberBarrier.doError(Throwable): void
removed: method SubscriberBarrier.doNext(Object): void
removed: method SubscriberBarrier.doRequest(long): void
removed: method SubscriberBarrier.doSubscribe(Subscription): void
removed: method SubscriberBarrier.getCapacity(): long
removed: method SubscriberBarrier.isReactivePull(Dispatcher, long): boolean
removed: method SubscriberBarrier.onComplete(): void
removed: method SubscriberBarrier.onError(Throwable): void
removed: method SubscriberBarrier.onNext(Object): void
removed: method SubscriberBarrier.onSubscribe(Subscription): void
removed: method SubscriberBarrier.request(long): void
removed: method SubscriberWithContext.context(): Object
removed: method SubscriberWithContext.isCancelled(): boolean
removed: method SubscriberWithContext.onComplete(): void
removed: method SubscriberWithContext.onError(Throwable): void
removed: method SubscriberWithContext.onNext(Object): void
removed: method SubscriberWithContext.onSubscribe(Subscription): void
removed: method SubscriptionWithContext.cancel(): void
removed: method SubscriptionWithContext.context(): Object
removed: method SubscriptionWithContext.isCancelled(): boolean
removed: method SubscriptionWithContext.request(long): void
removed: static class PublisherFactory.PrematureCompleteException extends RuntimeException
removed: static field PublisherFactory.PrematureCompleteException.INSTANCE: PublisherFactory.PrematureCompleteException
removed: static field SubscriberWithContext.TERMINAL_UPDATER: AtomicIntegerFieldUpdater
removed: static field SubscriptionWithContext.PENDING_UPDATER: AtomicLongFieldUpdater
removed: static field SubscriptionWithContext.TERMINATED_UPDATER: AtomicIntegerFieldUpdater
removed: static method PublisherFactory.barrier(Publisher, BiConsumer): Publisher
removed: static method PublisherFactory.barrier(Publisher, BiConsumer, BiConsumer): Publisher
removed: static method PublisherFactory.barrier(Publisher, BiConsumer, BiConsumer, Consumer): Publisher
removed: static method PublisherFactory.create(BiConsumer): Publisher
removed: static method PublisherFactory.create(BiConsumer, Function): Publisher
removed: static method PublisherFactory.create(BiConsumer, Function, Consumer): Publisher
removed: static method PublisherFactory.forEach(Consumer): Publisher
removed: static method PublisherFactory.forEach(Consumer, Function): Publisher
removed: static method PublisherFactory.forEach(Consumer, Function, Consumer): Publisher
removed: static method PublisherFactory.intercept(Publisher, Function): Publisher
removed: static method SerializedSubscriber.create(Subscriber): SerializedSubscriber
removed: static method SubscriberFactory.create(Consumer): Subscriber
removed: static method SubscriberFactory.create(Function, BiConsumer): Subscriber
removed: static method SubscriberFactory.create(Function, BiConsumer, BiConsumer): Subscriber
removed: static method SubscriberFactory.create(Function, BiConsumer, BiConsumer, Consumer): Subscriber
removed: static method SubscriberFactory.unbounded(): Subscriber
removed: static method SubscriberFactory.unbounded(BiConsumer): Subscriber
removed: static method SubscriberFactory.unbounded(BiConsumer, Consumer): Subscriber
removed: static method SubscriberFactory.unbounded(BiConsumer, Consumer, Consumer): Subscriber
removed: static method SubscriberWithContext.create(Subscriber, Object): SubscriberWithContext
removed: static method SubscriptionWithContext.create(Subscription, Object): SubscriptionWithContext

added: abstract class Schedulers
added: ctor ReactorBlockHoundIntegration()
added: ctor Schedulers()
added: final class ReactorBlockHoundIntegration implements BlockHoundIntegration
added: interface NonBlocking
added: interface Scheduler extends Disposable
added: interface Scheduler.Worker extends Disposable
added: interface Schedulers.Factory
added: method ReactorBlockHoundIntegration.applyTo(BlockHound.Builder): void
added: method Scheduler.Worker.schedule(Runnable): Disposable
added: method Scheduler.Worker.schedule(Runnable, long, TimeUnit): Disposable
added: method Scheduler.Worker.schedulePeriodically(Runnable, long, long, TimeUnit): Disposable
added: method Scheduler.createWorker(): Scheduler.Worker
added: method Scheduler.dispose(): void
added: method Scheduler.disposeGracefully(): Mono
added: method Scheduler.init(): void
added: method Scheduler.now(TimeUnit): long
added: method Scheduler.schedule(Runnable): Disposable
added: method Scheduler.schedule(Runnable, long, TimeUnit): Disposable
added: method Scheduler.schedulePeriodically(Runnable, long, long, TimeUnit): Disposable
added: method Scheduler.start(): void
added: method Schedulers.Factory.newBoundedElastic(int, int, ThreadFactory, int): Scheduler
added: method Schedulers.Factory.newParallel(int, ThreadFactory): Scheduler
added: method Schedulers.Factory.newSingle(ThreadFactory): Scheduler
added: method Schedulers.Factory.newThreadPerTaskBoundedElastic(int, int, ThreadFactory): Scheduler
added: method Schedulers.Snapshot.dispose(): void
added: method Schedulers.Snapshot.isDisposed(): boolean
added: static field Schedulers.DEFAULT_BOUNDED_ELASTIC_ON_VIRTUAL_THREADS: boolean
added: static field Schedulers.DEFAULT_BOUNDED_ELASTIC_QUEUESIZE: int
added: static field Schedulers.DEFAULT_BOUNDED_ELASTIC_SIZE: int
added: static field Schedulers.DEFAULT_POOL_SIZE: int
added: static final class Schedulers.Snapshot implements Disposable
added: static method Schedulers.addExecutorServiceDecorator(String, BiFunction): boolean
added: static method Schedulers.boundedElastic(): Scheduler
added: static method Schedulers.decorateExecutorService(Scheduler, ScheduledExecutorService): ScheduledExecutorService
added: static method Schedulers.disableMetrics(): void
added: static method Schedulers.enableMetrics(): void
added: static method Schedulers.fromExecutor(Executor): Scheduler
added: static method Schedulers.fromExecutor(Executor, boolean): Scheduler
added: static method Schedulers.fromExecutorService(ExecutorService): Scheduler
added: static method Schedulers.fromExecutorService(ExecutorService, String): Scheduler
added: static method Schedulers.immediate(): Scheduler
added: static method Schedulers.isInNonBlockingThread(): boolean
added: static method Schedulers.isNonBlockingThread(Thread): boolean
added: static method Schedulers.newBoundedElastic(int, int, String): Scheduler
added: static method Schedulers.newBoundedElastic(int, int, String, int): Scheduler
added: static method Schedulers.newBoundedElastic(int, int, String, int, boolean): Scheduler
added: static method Schedulers.newBoundedElastic(int, int, ThreadFactory, int): Scheduler
added: static method Schedulers.newParallel(String): Scheduler
added: static method Schedulers.newParallel(String, int): Scheduler
added: static method Schedulers.newParallel(String, int, boolean): Scheduler
added: static method Schedulers.newParallel(int, ThreadFactory): Scheduler
added: static method Schedulers.newSingle(String): Scheduler
added: static method Schedulers.newSingle(String, boolean): Scheduler
added: static method Schedulers.newSingle(ThreadFactory): Scheduler
added: static method Schedulers.onHandleError(BiConsumer): void
added: static method Schedulers.onHandleError(String, BiConsumer): void
added: static method Schedulers.onSchedule(Runnable): Runnable
added: static method Schedulers.onScheduleHook(String, Function): void
added: static method Schedulers.parallel(): Scheduler
added: static method Schedulers.registerNonBlockingThreadPredicate(Predicate): void
added: static method Schedulers.removeExecutorServiceDecorator(String): BiFunction
added: static method Schedulers.resetFactory(): void
added: static method Schedulers.resetFrom(Schedulers.Snapshot): void
added: static method Schedulers.resetNonBlockingThreadPredicate(): void
added: static method Schedulers.resetOnHandleError(): void
added: static method Schedulers.resetOnHandleError(String): void
added: static method Schedulers.resetOnScheduleHook(String): void
added: static method Schedulers.resetOnScheduleHooks(): void
added: static method Schedulers.setExecutorServiceDecorator(String, BiFunction): void
added: static method Schedulers.setFactory(Schedulers.Factory): void
added: static method Schedulers.setFactoryWithSnapshot(Schedulers.Factory): Schedulers.Snapshot
added: static method Schedulers.shutdownNow(): void
added: static method Schedulers.single(): Scheduler
added: static method Schedulers.single(Scheduler): Scheduler

removed: abstract class Assert
removed: abstract class UUIDUtils
removed: class NamedDaemonThreadFactory implements ThreadFactory
removed: class ReactorFatalException extends RuntimeException
removed: ctor Assert()
removed: ctor Exceptions()
removed: ctor Exceptions.ValueCause(Object)
removed: ctor NamedDaemonThreadFactory(String)
removed: ctor NamedDaemonThreadFactory(String, ClassLoader)
removed: ctor NamedDaemonThreadFactory(String, ClassLoader, Thread.UncaughtExceptionHandler, boolean)
removed: ctor SpecificationExceptions()
removed: final class Exceptions
removed: final class SpecificationExceptions
removed: interface NonBlocking
removed: interface Recyclable
removed: method Exceptions.ValueCause.getValue(): Object
removed: method NamedDaemonThreadFactory.newThread(Runnable): Thread
removed: method NonBlocking.getCapacity(): long
removed: method NonBlocking.isReactivePull(Dispatcher, long): boolean
removed: method Recyclable.recycle(): void
removed: static class Exceptions.ValueCause extends RuntimeException
removed: static field ReactorFatalException.INSTANCE: ReactorFatalException
removed: static method Assert.isAssignable(Class, Class, String): void
removed: static method Assert.isInstanceOf(Class, Object, String): void
removed: static method Assert.isNull(Object, String): void
removed: static method Assert.isTrue(boolean): void
removed: static method Assert.isTrue(boolean, String): void
removed: static method Assert.notEmpty(Object[], String): void
removed: static method Assert.notNull(Object): void
removed: static method Assert.notNull(Object, String): void
removed: static method Assert.state(boolean): void
removed: static method Assert.state(boolean, String): void
removed: static method Exceptions.addCause(Throwable, Throwable): void
removed: static method Exceptions.addValueAsLastCause(Throwable, Object): Throwable
removed: static method Exceptions.getFinalCause(Throwable): Throwable
removed: static method Exceptions.getFinalValueCause(Throwable): Object
removed: static method Exceptions.throwIfFatal(Throwable): void
removed: static method ReactorFatalException.create(Throwable): ReactorFatalException
removed: static method ReactorFatalException.instance(): ReactorFatalException
removed: static method SpecificationExceptions.spec_2_12_exception(): IllegalStateException
removed: static method SpecificationExceptions.spec_2_13_exception(): NullPointerException
removed: static method SpecificationExceptions.spec_3_09_exception(long): IllegalArgumentException
removed: static method UUIDUtils.create(): UUID
removed: static method UUIDUtils.random(): UUID

removed: abstract class Functions
removed: abstract class Predicates
removed: abstract class Suppliers
removed: ctor Functions()
removed: ctor Predicates()
removed: interface BiConsumer
removed: interface BiFunction
removed: interface Consumer
removed: interface Function
removed: interface Pausable
removed: interface Predicate
removed: interface Resource
removed: interface Supplier
removed: method BiConsumer.accept(Object, Object): void
removed: method BiFunction.apply(Object, Object): Object
removed: method Consumer.accept(Object): void
removed: method Function.apply(Object): Object
removed: method Pausable.cancel(): Pausable
removed: method Pausable.pause(): Pausable
removed: method Pausable.resume(): Pausable
removed: method Predicate.test(Object): boolean
removed: method Resource.alive(): boolean
removed: method Resource.awaitAndShutdown(): boolean
removed: method Resource.awaitAndShutdown(long, TimeUnit): boolean
removed: method Resource.forceShutdown(): void
removed: method Resource.shutdown(): void
removed: method Supplier.get(): Object
removed: static method Functions.chain(Consumer[]): Consumer
removed: static method Functions.consumer(Runnable): Consumer
removed: static method Functions.function(Callable): Function
removed: static method Functions.functionFrom(BiFunction): Function
removed: static method Functions.pairFrom(Function): BiFunction
removed: static method Functions.supplier(Callable): Supplier
removed: static method Functions.supplier(Class): Supplier
removed: static method Functions.supplier(Future): Supplier
removed: static method Functions.supplier(Object): Supplier
removed: static method Predicates.always(): Predicate
removed: static method Predicates.and(Predicate[]): Predicate
removed: static method Predicates.negate(Predicate): Predicate
removed: static method Predicates.never(): Predicate
removed: static method Predicates.or(Predicate, Predicate): Predicate
removed: static method Predicates.xor(Predicate, Predicate): Predicate
removed: static method Suppliers.collect(List): Supplier
removed: static method Suppliers.drain(Iterable): Supplier
removed: static method Suppliers.drainAll(Iterable): Supplier
removed: static method Suppliers.filter(Iterable, Predicate): Supplier
removed: static method Suppliers.roundRobin(Object[]): Supplier
removed: static method Suppliers.supply(Object): Supplier
removed: static method Suppliers.supplyOnce(Object): Supplier
removed: static method Suppliers.supplyWhile(Object, Predicate): Supplier

removed: class Tap implements Consumer, Supplier
removed: ctor Tap()
removed: method Tap.accept(Object): void
removed: method Tap.get(): Object

removed: abstract class TimeUtils
removed: class HashWheelTimer implements Timer
removed: ctor HashWheelTimer()
removed: ctor HashWheelTimer(String, int, int, HashWheelTimer.WaitStrategy, Executor)
removed: ctor HashWheelTimer(int)
removed: ctor HashWheelTimer(int, int, HashWheelTimer.WaitStrategy)
removed: ctor HashWheelTimer.BusySpinWait()
removed: ctor HashWheelTimer.SleepWait()
removed: ctor HashWheelTimer.TimerPausable(long, long, Consumer, long)
removed: ctor HashWheelTimer.YieldingWait()
removed: ctor TimeUtils()
removed: interface HashWheelTimer.WaitStrategy
removed: interface Timer
removed: method HashWheelTimer.BusySpinWait.waitUntil(long): void
removed: method HashWheelTimer.SleepWait.waitUntil(long): void
removed: method HashWheelTimer.TimerPausable.cancel(): HashWheelTimer.TimerPausable
removed: method HashWheelTimer.TimerPausable.cancelAfterUse(): HashWheelTimer.TimerPausable
removed: method HashWheelTimer.TimerPausable.compareTo(Object): int
removed: method HashWheelTimer.TimerPausable.decrement(): void
removed: method HashWheelTimer.TimerPausable.getOffset(): long
removed: method HashWheelTimer.TimerPausable.isCancelAfterUse(): boolean
removed: method HashWheelTimer.TimerPausable.isCancelled(): boolean
removed: method HashWheelTimer.TimerPausable.isPaused(): boolean
removed: method HashWheelTimer.TimerPausable.pause(): HashWheelTimer.TimerPausable
removed: method HashWheelTimer.TimerPausable.ready(): boolean
removed: method HashWheelTimer.TimerPausable.reset(): void
removed: method HashWheelTimer.TimerPausable.resume(): HashWheelTimer.TimerPausable
removed: method HashWheelTimer.TimerPausable.run(): void
removed: method HashWheelTimer.TimerPausable.toString(): String
removed: method HashWheelTimer.WaitStrategy.waitUntil(long): void
removed: method HashWheelTimer.YieldingWait.waitUntil(long): void
removed: method HashWheelTimer.cancel(): void
removed: method HashWheelTimer.getResolution(): long
removed: method HashWheelTimer.schedule(Consumer, long, TimeUnit): Pausable
removed: method HashWheelTimer.schedule(Consumer, long, TimeUnit, long): Pausable
removed: method HashWheelTimer.start(): void
removed: method HashWheelTimer.submit(Consumer): Pausable
removed: method HashWheelTimer.submit(Consumer, long, TimeUnit): Pausable
removed: method HashWheelTimer.toString(): String
removed: method Timer.cancel(): void
removed: method Timer.getResolution(): long
removed: method Timer.schedule(Consumer, long, TimeUnit): Pausable
removed: method Timer.schedule(Consumer, long, TimeUnit, long): Pausable
removed: method Timer.submit(Consumer): Pausable
removed: method Timer.submit(Consumer, long, TimeUnit): Pausable
removed: static class HashWheelTimer.BusySpinWait implements HashWheelTimer.WaitStrategy
removed: static class HashWheelTimer.SleepWait implements HashWheelTimer.WaitStrategy
removed: static class HashWheelTimer.TimerPausable implements Runnable, Comparable, Pausable
removed: static class HashWheelTimer.YieldingWait implements HashWheelTimer.WaitStrategy
removed: static field HashWheelTimer.DEFAULT_WHEEL_SIZE: int
removed: static field HashWheelTimer.TimerPausable.STATUS_CANCELLED: int
removed: static field HashWheelTimer.TimerPausable.STATUS_PAUSED: int
removed: static field HashWheelTimer.TimerPausable.STATUS_READY: int
removed: static method TimeUtils.approxCurrentTimeMillis(): long
removed: static method TimeUtils.checkResolution(long, long): void
removed: static method TimeUtils.getTimer(): Timer
removed: static method TimeUtils.setTimer(Timer): void

removed: class Tuple implements Iterable, Serializable
removed: class Tuple1 extends Tuple
removed: class Tuple2 extends Tuple1
removed: class Tuple3 extends Tuple2
removed: class Tuple4 extends Tuple3
removed: class Tuple5 extends Tuple4
removed: class Tuple6 extends Tuple5
removed: class Tuple7 extends Tuple6
removed: class Tuple8 extends Tuple7
removed: class TupleN extends Tuple8
removed: ctor Tuple(int)
removed: field Tuple.size: int
removed: field Tuple1.t1: Object
removed: field Tuple2.t2: Object
removed: field Tuple3.t3: Object
removed: field Tuple4.t4: Object
removed: field Tuple5.t5: Object
removed: field Tuple6.t6: Object
removed: field Tuple7.t7: Object
removed: field Tuple8.t8: Object
removed: field TupleN.entries: Object[]
removed: method Tuple.equals(Object): boolean
removed: method Tuple.get(int): Object
removed: method Tuple.hashCode(): int
removed: method Tuple.iterator(): Iterator
removed: method Tuple.size(): int
removed: method Tuple.toArray(): Object[]
removed: method Tuple1.equals(Object): boolean
removed: method Tuple1.get(int): Object
removed: method Tuple1.getT1(): Object
removed: method Tuple1.hashCode(): int
removed: method Tuple1.iterator(): Iterator
removed: method Tuple1.toArray(): Object[]
removed: method Tuple1.toString(): String
removed: method Tuple2.equals(Object): boolean
removed: method Tuple2.get(int): Object
removed: method Tuple2.getT2(): Object
removed: method Tuple2.hashCode(): int
removed: method Tuple2.iterator(): Iterator
removed: method Tuple2.toArray(): Object[]
removed: method Tuple2.toString(): String
removed: method Tuple3.equals(Object): boolean
removed: method Tuple3.get(int): Object
removed: method Tuple3.getT3(): Object
removed: method Tuple3.hashCode(): int
removed: method Tuple3.iterator(): Iterator
removed: method Tuple3.toArray(): Object[]
removed: method Tuple3.toString(): String
removed: method Tuple4.equals(Object): boolean
removed: method Tuple4.get(int): Object
removed: method Tuple4.getT4(): Object
removed: method Tuple4.hashCode(): int
removed: method Tuple4.iterator(): Iterator
removed: method Tuple4.toArray(): Object[]
removed: method Tuple4.toString(): String
removed: method Tuple5.equals(Object): boolean
removed: method Tuple5.get(int): Object
removed: method Tuple5.getT5(): Object
removed: method Tuple5.hashCode(): int
removed: method Tuple5.iterator(): Iterator
removed: method Tuple5.toArray(): Object[]
removed: method Tuple5.toString(): String
removed: method Tuple6.equals(Object): boolean
removed: method Tuple6.get(int): Object
removed: method Tuple6.getT6(): Object
removed: method Tuple6.hashCode(): int
removed: method Tuple6.iterator(): Iterator
removed: method Tuple6.toArray(): Object[]
removed: method Tuple6.toString(): String
removed: method Tuple7.equals(Object): boolean
removed: method Tuple7.get(int): Object
removed: method Tuple7.getT7(): Object
removed: method Tuple7.hashCode(): int
removed: method Tuple7.iterator(): Iterator
removed: method Tuple7.toArray(): Object[]
removed: method Tuple7.toString(): String
removed: method Tuple8.equals(Object): boolean
removed: method Tuple8.get(int): Object
removed: method Tuple8.getT8(): Object
removed: method Tuple8.hashCode(): int
removed: method Tuple8.iterator(): Iterator
removed: method Tuple8.toArray(): Object[]
removed: method Tuple8.toString(): String
removed: method TupleN.equals(Object): boolean
removed: method TupleN.get(int): Object
removed: method TupleN.getT1(): Object
removed: method TupleN.getT2(): Object
removed: method TupleN.getT3(): Object
removed: method TupleN.getT4(): Object
removed: method TupleN.getT5(): Object
removed: method TupleN.getT6(): Object
removed: method TupleN.getT7(): Object
removed: method TupleN.getT8(): Object
removed: method TupleN.hashCode(): int
removed: method TupleN.iterator(): Iterator
removed: method TupleN.toArray(): Object[]
removed: method TupleN.toString(): String
removed: static method Tuple.empty(): Tuple
removed: static method Tuple.of(List): TupleN
removed: static method Tuple.of(Object): Tuple1
removed: static method Tuple.of(Object, Object): Tuple2
removed: static method Tuple.of(Object, Object, Object): Tuple3
removed: static method Tuple.of(Object, Object, Object, Object): Tuple4
removed: static method Tuple.of(Object, Object, Object, Object, Object): Tuple5
removed: static method Tuple.of(Object, Object, Object, Object, Object, Object): Tuple6
removed: static method Tuple.of(Object, Object, Object, Object, Object, Object, Object): Tuple7
removed: static method Tuple.of(Object, Object, Object, Object, Object, Object, Object, Object): Tuple8
removed: static method Tuple.of(Object[]): TupleN

removed: ctor IO.FileContext(RandomAccessFile)
removed: final class IO
removed: method IO.FileContext.close(): void
removed: method IO.FileContext.file(): RandomAccessFile
removed: method IO.FileContext.isOpen(): boolean
removed: method IO.FileContext.read(ByteBuffer): int
removed: static final class IO.FileContext implements ReadableByteChannel
removed: static method IO.read(ReadableByteChannel): Publisher
removed: static method IO.read(ReadableByteChannel, int): Publisher
removed: static method IO.readFile(Path): Publisher
removed: static method IO.readFile(Path, int): Publisher
removed: static method IO.readFile(String): Publisher
removed: static method IO.readFile(String, int): Publisher

removed: class Buffer implements Recyclable, Comparable, Iterable, ReadableByteChannel, WritableByteChannel
removed: class Buffer.View implements Supplier
removed: ctor Buffer()
removed: ctor Buffer(Buffer)
removed: ctor Buffer(ByteBuffer)
removed: ctor Buffer(int, boolean)
removed: method Buffer.View.get(): Buffer
removed: method Buffer.View.getEnd(): int
removed: method Buffer.View.getStart(): int
removed: method Buffer.append(Buffer[]): Buffer
removed: method Buffer.append(ByteBuffer[]): Buffer
removed: method Buffer.append(String): Buffer
removed: method Buffer.append(byte): Buffer
removed: method Buffer.append(byte[]): Buffer
removed: method Buffer.append(byte[], int, int): Buffer
removed: method Buffer.append(char): Buffer
removed: method Buffer.append(int): Buffer
removed: method Buffer.append(long): Buffer
removed: method Buffer.append(short): Buffer
removed: method Buffer.asBytes(): byte[]
removed: method Buffer.asString(): String
removed: method Buffer.byteBuffer(): ByteBuffer
removed: method Buffer.capacity(): int
removed: method Buffer.clear(): Buffer
removed: method Buffer.close(): void
removed: method Buffer.compact(): Buffer
removed: method Buffer.compareTo(Buffer): int
removed: method Buffer.copy(): Buffer
removed: method Buffer.createView(): Buffer.View
removed: method Buffer.createView(int, int): Buffer.View
removed: method Buffer.duplicate(): Buffer
removed: method Buffer.first(): byte
removed: method Buffer.flip(): Buffer
removed: method Buffer.indexOf(byte): int
removed: method Buffer.indexOf(byte, int, int): int
removed: method Buffer.inputStream(): InputStream
removed: method Buffer.isDelimitingBuffer(): boolean
removed: method Buffer.isDynamic(): boolean
removed: method Buffer.isOpen(): boolean
removed: method Buffer.iterator(): Iterator
removed: method Buffer.last(): byte
removed: method Buffer.limit(): int
removed: method Buffer.limit(int): Buffer
removed: method Buffer.position(): int
removed: method Buffer.position(int): Buffer
removed: method Buffer.prepend(Buffer): Buffer
removed: method Buffer.prepend(ByteBuffer): Buffer
removed: method Buffer.prepend(String): Buffer
removed: method Buffer.prepend(byte): Buffer
removed: method Buffer.prepend(byte[]): Buffer
removed: method Buffer.prepend(char): Buffer
removed: method Buffer.prepend(int): Buffer
removed: method Buffer.prepend(long): Buffer
removed: method Buffer.prepend(short): Buffer
removed: method Buffer.read(): byte
removed: method Buffer.read(ByteBuffer): int
removed: method Buffer.read(byte[]): Buffer
removed: method Buffer.readChar(): char
removed: method Buffer.readDouble(): double
removed: method Buffer.readFloat(): float
removed: method Buffer.readInt(): int
removed: method Buffer.readLong(): long
removed: method Buffer.readShort(): short
removed: method Buffer.recycle(): void
removed: method Buffer.remaining(): int
removed: method Buffer.reset(): Buffer
removed: method Buffer.rewind(): Buffer
removed: method Buffer.rewind(int): Buffer
removed: method Buffer.skip(int): Buffer
removed: method Buffer.slice(int, int): Buffer
removed: method Buffer.slice(int[]): List
removed: method Buffer.snapshot(): void
removed: method Buffer.split(Buffer): Iterable
removed: method Buffer.split(Buffer, boolean): Iterable
removed: method Buffer.split(List, Buffer, boolean): Iterable
removed: method Buffer.split(List, int): List
removed: method Buffer.split(List, int, boolean): List
removed: method Buffer.split(int): List
removed: method Buffer.split(int, boolean): List
removed: method Buffer.substring(int, int): String
removed: method Buffer.toString(): String
removed: method Buffer.write(ByteBuffer): int
removed: static field Buffer.DELIMITING_BUFFER: Buffer
removed: static field Buffer.MAX_BUFFER_SIZE: int
removed: static field Buffer.SMALL_BUFFER_SIZE: int
removed: static method Buffer.parseInt(Buffer): Integer
removed: static method Buffer.parseInt(Buffer, int, int): Integer
removed: static method Buffer.parseLong(Buffer): Long
removed: static method Buffer.parseLong(Buffer, int, int): Long
removed: static method Buffer.wrap(String): Buffer
removed: static method Buffer.wrap(String, boolean): Buffer
removed: static method Buffer.wrap(byte[]): Buffer

removed: abstract class BufferCodec extends Codec
removed: abstract class Codec implements Function
removed: abstract class SerializationCodec extends BufferCodec
removed: abstract class StandardCodecs
removed: class ByteArrayCodec extends BufferCodec
removed: class DelimitedCodec extends BufferCodec
removed: class Frame
removed: class FrameCodec extends BufferCodec
removed: class JavaSerializationCodec extends BufferCodec
removed: class LengthFieldCodec extends BufferCodec
removed: class PassThroughCodec extends Codec
removed: class StringCodec extends BufferCodec
removed: ctor BufferCodec()
removed: ctor BufferCodec(Byte)
removed: ctor ByteArrayCodec()
removed: ctor Codec()
removed: ctor Codec(Byte)
removed: ctor DelimitedCodec(Codec)
removed: ctor DelimitedCodec(boolean, Codec)
removed: ctor DelimitedCodec(byte, boolean, Codec)
removed: ctor Frame(Buffer, Buffer)
removed: ctor FrameCodec(int, FrameCodec.LengthField)
removed: ctor JavaSerializationCodec()
removed: ctor LengthFieldCodec(Codec)
removed: ctor LengthFieldCodec(int, Codec)
removed: ctor PassThroughCodec()
removed: ctor SerializationCodec(Object, boolean)
removed: ctor StringCodec()
removed: ctor StringCodec(Byte)
removed: ctor StringCodec(Byte, Charset)
removed: ctor StringCodec(Charset)
removed: ctor StringCodec.StringEncoder(StringCodec)
removed: enum FrameCodec.LengthField
removed: field Codec.delimiter: Byte
removed: final class StringCodec.StringEncoder implements Function
removed: method BufferCodec.decode(Publisher): Publisher
removed: method BufferCodec.encode(Publisher): Publisher
removed: method ByteArrayCodec.apply(byte[]): Buffer
removed: method ByteArrayCodec.decoder(Consumer): Function
removed: method Codec.addDelimiterIfAny(Buffer): Buffer
removed: method Codec.decode(Publisher): Publisher
removed: method Codec.decoder(): Function
removed: method Codec.decoder(Consumer): Function
removed: method Codec.doBufferDecode(Buffer): Object
removed: method Codec.doDelimitedBufferDecode(Consumer, Buffer): Object
removed: method Codec.encode(Publisher): Publisher
removed: method Codec.encoder(): Function
removed: method DelimitedCodec.apply(Object): Buffer
removed: method DelimitedCodec.decoder(Consumer): Function
removed: method Frame.getData(): Buffer
removed: method Frame.getPrefix(): Buffer
removed: method FrameCodec.apply(Frame): Buffer
removed: method FrameCodec.decoder(Consumer): Function
removed: method JavaSerializationCodec.apply(Object): Buffer
removed: method JavaSerializationCodec.decoder(Consumer): Function
removed: method LengthFieldCodec.apply(Object): Buffer
removed: method LengthFieldCodec.decoder(Consumer): Function
removed: method PassThroughCodec.apply(Object): Object
removed: method PassThroughCodec.beforeAccept(Object): Object
removed: method PassThroughCodec.beforeApply(Object): Object
removed: method PassThroughCodec.decoder(Consumer): Function
removed: method SerializationCodec.apply(Object): Buffer
removed: method SerializationCodec.decoder(Consumer): Function
removed: method SerializationCodec.deserializer(Object, Class, Consumer): Function
removed: method SerializationCodec.getEngine(): Object
removed: method SerializationCodec.readType(Buffer): Class
removed: method SerializationCodec.serializer(Object): Function
removed: method StringCodec.StringEncoder.apply(String): Buffer
removed: method StringCodec.apply(String): Buffer
removed: method StringCodec.decode(Buffer, CharsetDecoder): String
removed: method StringCodec.decoder(Consumer): Function
removed: method StringCodec.doBufferDecode(Buffer): String
removed: method StringCodec.encode(String, CharsetEncoder): Buffer
removed: method StringCodec.encoder(): Function
removed: static field Codec.DEFAULT_DELIMITER: byte
removed: static field FrameCodec.LengthField.INT: FrameCodec.LengthField
removed: static field FrameCodec.LengthField.LONG: FrameCodec.LengthField
removed: static field FrameCodec.LengthField.SHORT: FrameCodec.LengthField
removed: static field StandardCodecs.BYTE_ARRAY_CODEC: ByteArrayCodec
removed: static field StandardCodecs.DELIMITED_STRING_CODEC: StringCodec
removed: static field StandardCodecs.LINE_FEED_CODEC: DelimitedCodec
removed: static field StandardCodecs.PASS_THROUGH_CODEC: Codec
removed: static field StandardCodecs.STRING_CODEC: StringCodec
removed: static method Codec.invokeCallbackOrReturn(Consumer, Object): Object
removed: static method FrameCodec.LengthField.valueOf(String): FrameCodec.LengthField
removed: static method FrameCodec.LengthField.values(): FrameCodec.LengthField[]

removed: abstract class CompressionCodec extends BufferCodec
removed: class GzipCodec extends CompressionCodec
removed: class SnappyCodec extends CompressionCodec
removed: ctor CompressionCodec(Codec)
removed: ctor GzipCodec(Codec)
removed: ctor SnappyCodec(Codec)
removed: method CompressionCodec.apply(Object): Buffer
removed: method CompressionCodec.createInputStream(InputStream): InputStream
removed: method CompressionCodec.createOutputStream(OutputStream): OutputStream
removed: method CompressionCodec.decoder(Consumer): Function
removed: method GzipCodec.createInputStream(InputStream): InputStream
removed: method GzipCodec.createOutputStream(OutputStream): OutputStream
removed: method SnappyCodec.createInputStream(InputStream): InputStream
removed: method SnappyCodec.createOutputStream(OutputStream): OutputStream

removed: class JacksonJsonCodec extends SerializationCodec
removed: class JsonCodec extends BufferCodec
removed: ctor JacksonJsonCodec()
removed: ctor JacksonJsonCodec(ObjectMapper)
removed: ctor JsonCodec(Class)
removed: ctor JsonCodec(Class, Module)
removed: ctor JsonCodec(Class, Module, Byte)
removed: method JacksonJsonCodec.deserializer(ObjectMapper, Class, Consumer): Function
removed: method JacksonJsonCodec.serializer(ObjectMapper): Function
removed: method JsonCodec.apply(Object): Buffer
removed: method JsonCodec.decoder(Consumer): Function
removed: method JsonCodec.doBufferDecode(Buffer): Object

removed: class KryoCodec extends SerializationCodec
removed: class KryoPoolCodec extends SerializationCodec
removed: ctor KryoCodec()
removed: ctor KryoCodec(Kryo, boolean)
removed: ctor KryoPoolCodec()
removed: ctor KryoPoolCodec(KryoFactory, boolean)
removed: ctor KryoPoolCodec(KryoPool, boolean)
removed: method KryoCodec.deserializer(Kryo, Class, Consumer): Function
removed: method KryoCodec.serializer(Kryo): Function
removed: method KryoPoolCodec.deserializer(KryoPool, Class, Consumer): Function
removed: method KryoPoolCodec.serializer(KryoPool): Function

removed: class ProtobufCodec extends SerializationCodec
removed: ctor ProtobufCodec()
removed: ctor ProtobufCodec(boolean)
removed: method ProtobufCodec.deserializer(Map, Class, Consumer): Function
removed: method ProtobufCodec.serializer(Map): Function

removed: class ChronicleQueuePersistor implements QueuePersistor
removed: class InMemoryQueuePersistor implements QueuePersistor
removed: class PersistentQueue extends AbstractQueue implements CompletableQueue
removed: ctor ChronicleQueuePersistor(String)
removed: ctor ChronicleQueuePersistor(String, Codec, boolean, boolean, ChronicleQueueBuilder)
removed: ctor InMemoryQueuePersistor()
removed: ctor PersistentQueue(QueuePersistor)
removed: interface QueuePersistor extends Iterable
removed: method ChronicleQueuePersistor.close(): void
removed: method ChronicleQueuePersistor.codec(): Codec
removed: method ChronicleQueuePersistor.get(Long): Object
removed: method ChronicleQueuePersistor.hasNext(): boolean
removed: method ChronicleQueuePersistor.iterator(): Iterator
removed: method ChronicleQueuePersistor.lastId(): long
removed: method ChronicleQueuePersistor.offer(Object): Long
removed: method ChronicleQueuePersistor.offerAll(Collection): Long
removed: method ChronicleQueuePersistor.reader(): ExcerptTailer
removed: method ChronicleQueuePersistor.remove(): Object
removed: method ChronicleQueuePersistor.size(): long
removed: method InMemoryQueuePersistor.close(): void
removed: method InMemoryQueuePersistor.get(Long): Object
removed: method InMemoryQueuePersistor.hasNext(): boolean
removed: method InMemoryQueuePersistor.iterator(): Iterator
removed: method InMemoryQueuePersistor.lastId(): long
removed: method InMemoryQueuePersistor.offer(Object): Long
removed: method InMemoryQueuePersistor.offerAll(Collection): Long
removed: method InMemoryQueuePersistor.refMap(): Map
removed: method InMemoryQueuePersistor.remove(): Object
removed: method InMemoryQueuePersistor.size(): long
removed: method PersistentQueue.close(): void
removed: method PersistentQueue.complete(): void
removed: method PersistentQueue.isComplete(): boolean
removed: method PersistentQueue.iterator(): Iterator
removed: method PersistentQueue.offer(Object): boolean
removed: method PersistentQueue.peek(): Object
removed: method PersistentQueue.poll(): Object
removed: method PersistentQueue.size(): int
removed: method QueuePersistor.close(): void
removed: method QueuePersistor.get(Long): Object
removed: method QueuePersistor.hasNext(): boolean
removed: method QueuePersistor.lastId(): long
removed: method QueuePersistor.offer(Object): Long
removed: method QueuePersistor.offerAll(Collection): Long
removed: method QueuePersistor.remove(): Object
removed: method QueuePersistor.size(): long

removed: class PersistentQueueSpec implements Supplier
removed: ctor PersistentQueueSpec()
removed: method PersistentQueueSpec.basePath(String): PersistentQueueSpec
removed: method PersistentQueueSpec.clearOnStart(boolean): PersistentQueueSpec
removed: method PersistentQueueSpec.codec(Codec): PersistentQueueSpec
removed: method PersistentQueueSpec.dataBlockSize(int): PersistentQueueSpec
removed: method PersistentQueueSpec.deleteOnExit(boolean): PersistentQueueSpec
removed: method PersistentQueueSpec.get(): PersistentQueue
removed: method PersistentQueueSpec.indexBlockSize(int): PersistentQueueSpec
removed: method PersistentQueueSpec.sync(boolean): PersistentQueueSpec
removed: static field PersistentQueueSpec.DEFAULT_BASE_PATH: String

removed: abstract class AbstractSequencer implements Sequencer
removed: class EventPoller
removed: class Sequence extends RhsPadding
removed: class TimeoutBlockingWaitStrategy implements WaitStrategy
removed: ctor AbstractSequencer(int, WaitStrategy)
removed: ctor AggregateEventHandler(EventHandler[])
removed: ctor BatchEventProcessor(DataProvider, SequenceBarrier, EventHandler)
removed: ctor BlockingWaitStrategy()
removed: ctor BusySpinWaitStrategy()
removed: ctor EventPoller(DataProvider, Sequencer, Sequence, Sequence)
removed: ctor FatalExceptionHandler()
removed: ctor FatalExceptionHandler(Logger)
removed: ctor FixedSequenceGroup(Sequence[])
removed: ctor IgnoreExceptionHandler()
removed: ctor IgnoreExceptionHandler(Logger)
removed: ctor LiteBlockingWaitStrategy()
removed: ctor MultiProducerSequencer(int, WaitStrategy)
removed: ctor NoOpEventProcessor(RingBuffer)
removed: ctor PhasedBackoffWaitStrategy(long, long, TimeUnit, WaitStrategy)
removed: ctor Sequence()
removed: ctor Sequence(long)
removed: ctor SequenceGroup()
removed: ctor SingleProducerSequencer(int, WaitStrategy)
removed: ctor SleepingWaitStrategy()
removed: ctor SleepingWaitStrategy(int)
removed: ctor TimeoutBlockingWaitStrategy(long, TimeUnit)
removed: ctor WorkProcessor(RingBuffer, SequenceBarrier, WorkHandler, ExceptionHandler, Sequence)
removed: ctor WorkerPool(EventFactory, ExceptionHandler, WorkHandler[])
removed: ctor WorkerPool(RingBuffer, SequenceBarrier, ExceptionHandler, WorkHandler[])
removed: ctor YieldingWaitStrategy()
removed: enum EventPoller.PollState
removed: field AbstractSequencer.bufferSize: int
removed: field AbstractSequencer.cursor: Sequence
removed: field AbstractSequencer.waitStrategy: WaitStrategy
removed: field RingBuffer.p1: long
removed: field RingBuffer.p2: long
removed: field RingBuffer.p3: long
removed: field RingBuffer.p4: long
removed: field RingBuffer.p5: long
removed: field RingBuffer.p6: long
removed: field RingBuffer.p7: long
removed: field SingleProducerSequencer.p1: long
removed: field SingleProducerSequencer.p2: long
removed: field SingleProducerSequencer.p3: long
removed: field SingleProducerSequencer.p4: long
removed: field SingleProducerSequencer.p5: long
removed: field SingleProducerSequencer.p6: long
removed: field SingleProducerSequencer.p7: long
removed: final class AggregateEventHandler implements EventHandler, LifecycleAware
removed: final class AlertException extends Exception
removed: final class BatchEventProcessor implements EventProcessor
removed: final class BlockingWaitStrategy implements WaitStrategy
removed: final class BusySpinWaitStrategy implements WaitStrategy
removed: final class FatalExceptionHandler implements ExceptionHandler
removed: final class FixedSequenceGroup extends Sequence
removed: final class IgnoreExceptionHandler implements ExceptionHandler
removed: final class InsufficientCapacityException extends Exception
removed: final class LiteBlockingWaitStrategy implements WaitStrategy
removed: final class MultiProducerSequencer extends AbstractSequencer
removed: final class NoOpEventProcessor implements EventProcessor
removed: final class PhasedBackoffWaitStrategy implements WaitStrategy
removed: final class RingBuffer extends RingBufferFields implements Cursored, EventSequencer, EventSink
removed: final class SequenceGroup extends Sequence
removed: final class SingleProducerSequencer extends SingleProducerSequencerFields
removed: final class SleepingWaitStrategy implements WaitStrategy
removed: final class TimeoutException extends Exception
removed: final class WorkProcessor implements EventProcessor
removed: final class WorkerPool
removed: final class YieldingWaitStrategy implements WaitStrategy
removed: interface Cursored
removed: interface DataProvider
removed: interface EventFactory
removed: interface EventHandler
removed: interface EventPoller.Handler
removed: interface EventProcessor extends Runnable
removed: interface EventReleaseAware
removed: interface EventReleaser
removed: interface EventSequencer extends DataProvider, Sequenced
removed: interface EventSink
removed: interface EventTranslator
removed: interface EventTranslatorOneArg
removed: interface EventTranslatorThreeArg
removed: interface EventTranslatorTwoArg
removed: interface EventTranslatorVararg
removed: interface ExceptionHandler
removed: interface LifecycleAware
removed: interface SequenceBarrier
removed: interface SequenceReportingEventHandler extends EventHandler
removed: interface Sequenced
removed: interface Sequencer extends Cursored, Sequenced
removed: interface TimeoutHandler
removed: interface WaitStrategy
removed: interface WorkHandler
removed: method AbstractSequencer.addGatingSequences(Sequence[]): void
removed: method AbstractSequencer.getBufferSize(): int
removed: method AbstractSequencer.getCursor(): long
removed: method AbstractSequencer.getMinimumSequence(): long
removed: method AbstractSequencer.newBarrier(Sequence[]): SequenceBarrier
removed: method AbstractSequencer.newPoller(DataProvider, Sequence[]): EventPoller
removed: method AbstractSequencer.removeGatingSequence(Sequence): boolean
removed: method AggregateEventHandler.onEvent(Object, long, boolean): void
removed: method AggregateEventHandler.onShutdown(): void
removed: method AggregateEventHandler.onStart(): void
removed: method AlertException.fillInStackTrace(): Throwable
removed: method BatchEventProcessor.getSequence(): Sequence
removed: method BatchEventProcessor.halt(): void
removed: method BatchEventProcessor.isRunning(): boolean
removed: method BatchEventProcessor.run(): void
removed: method BatchEventProcessor.setExceptionHandler(ExceptionHandler): void
removed: method BlockingWaitStrategy.signalAllWhenBlocking(): void
removed: method BlockingWaitStrategy.waitFor(long, Sequence, Sequence, SequenceBarrier): long
removed: method BusySpinWaitStrategy.signalAllWhenBlocking(): void
removed: method BusySpinWaitStrategy.waitFor(long, Sequence, Sequence, SequenceBarrier): long
removed: method Cursored.getCursor(): long
removed: method DataProvider.get(long): Object
removed: method EventFactory.newInstance(): Object
removed: method EventHandler.onEvent(Object, long, boolean): void
removed: method EventPoller.Handler.onEvent(Object, long, boolean): boolean
removed: method EventPoller.getSequence(): Sequence
removed: method EventPoller.poll(EventPoller.Handler): EventPoller.PollState
removed: method EventProcessor.getSequence(): Sequence
removed: method EventProcessor.halt(): void
removed: method EventProcessor.isRunning(): boolean
removed: method EventReleaseAware.setEventReleaser(EventReleaser): void
removed: method EventReleaser.release(): void
removed: method EventSink.publishEvent(EventTranslator): void
removed: method EventSink.publishEvent(EventTranslatorOneArg, Object): void
removed: method EventSink.publishEvent(EventTranslatorThreeArg, Object, Object, Object): void
removed: method EventSink.publishEvent(EventTranslatorTwoArg, Object, Object): void
removed: method EventSink.publishEvent(EventTranslatorVararg, Object[]): void
removed: method EventSink.publishEvents(EventTranslatorOneArg, Object[]): void
removed: method EventSink.publishEvents(EventTranslatorOneArg, int, int, Object[]): void
removed: method EventSink.publishEvents(EventTranslatorThreeArg, Object[], Object[], Object[]): void
removed: method EventSink.publishEvents(EventTranslatorThreeArg, int, int, Object[], Object[], Object[]): void
removed: method EventSink.publishEvents(EventTranslatorTwoArg, Object[], Object[]): void
removed: method EventSink.publishEvents(EventTranslatorTwoArg, int, int, Object[], Object[]): void
removed: method EventSink.publishEvents(EventTranslatorVararg, Object[][]): void
removed: method EventSink.publishEvents(EventTranslatorVararg, int, int, Object[][]): void
removed: method EventSink.publishEvents(EventTranslator[]): void
removed: method EventSink.publishEvents(EventTranslator[], int, int): void
removed: method EventSink.tryPublishEvent(EventTranslator): boolean
removed: method EventSink.tryPublishEvent(EventTranslatorOneArg, Object): boolean
removed: method EventSink.tryPublishEvent(EventTranslatorThreeArg, Object, Object, Object): boolean
removed: method EventSink.tryPublishEvent(EventTranslatorTwoArg, Object, Object): boolean
removed: method EventSink.tryPublishEvent(EventTranslatorVararg, Object[]): boolean
removed: method EventSink.tryPublishEvents(EventTranslatorOneArg, Object[]): boolean
removed: method EventSink.tryPublishEvents(EventTranslatorOneArg, int, int, Object[]): boolean
removed: method EventSink.tryPublishEvents(EventTranslatorThreeArg, Object[], Object[], Object[]): boolean
removed: method EventSink.tryPublishEvents(EventTranslatorThreeArg, int, int, Object[], Object[], Object[]): boolean
removed: method EventSink.tryPublishEvents(EventTranslatorTwoArg, Object[], Object[]): boolean
removed: method EventSink.tryPublishEvents(EventTranslatorTwoArg, int, int, Object[], Object[]): boolean
removed: method EventSink.tryPublishEvents(EventTranslatorVararg, Object[][]): boolean
removed: method EventSink.tryPublishEvents(EventTranslatorVararg, int, int, Object[][]): boolean
removed: method EventSink.tryPublishEvents(EventTranslator[]): boolean
removed: method EventSink.tryPublishEvents(EventTranslator[], int, int): boolean
removed: method EventTranslator.translateTo(Object, long): void
removed: method EventTranslatorOneArg.translateTo(Object, long, Object): void
removed: method EventTranslatorThreeArg.translateTo(Object, long, Object, Object, Object): void
removed: method EventTranslatorTwoArg.translateTo(Object, long, Object, Object): void
removed: method EventTranslatorVararg.translateTo(Object, long, Object[]): void
removed: method ExceptionHandler.handleEventException(Throwable, long, Object): void
removed: method ExceptionHandler.handleOnShutdownException(Throwable): void
removed: method ExceptionHandler.handleOnStartException(Throwable): void
removed: method FatalExceptionHandler.handleEventException(Throwable, long, Object): void
removed: method FatalExceptionHandler.handleOnShutdownException(Throwable): void
removed: method FatalExceptionHandler.handleOnStartException(Throwable): void
removed: method FixedSequenceGroup.addAndGet(long): long
removed: method FixedSequenceGroup.compareAndSet(long, long): boolean
removed: method FixedSequenceGroup.get(): long
removed: method FixedSequenceGroup.incrementAndGet(): long
removed: method FixedSequenceGroup.set(long): void
removed: method FixedSequenceGroup.toString(): String
removed: method IgnoreExceptionHandler.handleEventException(Throwable, long, Object): void
removed: method IgnoreExceptionHandler.handleOnShutdownException(Throwable): void
removed: method IgnoreExceptionHandler.handleOnStartException(Throwable): void
removed: method InsufficientCapacityException.fillInStackTrace(): Throwable
removed: method LifecycleAware.onShutdown(): void
removed: method LifecycleAware.onStart(): void
removed: method LiteBlockingWaitStrategy.signalAllWhenBlocking(): void
removed: method LiteBlockingWaitStrategy.waitFor(long, Sequence, Sequence, SequenceBarrier): long
removed: method MultiProducerSequencer.claim(long): void
removed: method MultiProducerSequencer.getHighestPublishedSequence(long, long): long
removed: method MultiProducerSequencer.hasAvailableCapacity(int): boolean
removed: method MultiProducerSequencer.isAvailable(long): boolean
removed: method MultiProducerSequencer.next(): long
removed: method MultiProducerSequencer.next(int): long
removed: method MultiProducerSequencer.publish(long): void
removed: method MultiProducerSequencer.publish(long, long): void
removed: method MultiProducerSequencer.remainingCapacity(): long
removed: method MultiProducerSequencer.tryNext(): long
removed: method MultiProducerSequencer.tryNext(int): long
removed: method NoOpEventProcessor.getSequence(): Sequence
removed: method NoOpEventProcessor.halt(): void
removed: method NoOpEventProcessor.isRunning(): boolean
removed: method NoOpEventProcessor.run(): void
removed: method PhasedBackoffWaitStrategy.signalAllWhenBlocking(): void
removed: method PhasedBackoffWaitStrategy.waitFor(long, Sequence, Sequence, SequenceBarrier): long
removed: method RingBuffer.addGatingSequences(Sequence[]): void
removed: method RingBuffer.claimAndGetPreallocated(long): Object
removed: method RingBuffer.get(long): Object
removed: method RingBuffer.getBufferSize(): int
removed: method RingBuffer.getCursor(): long
removed: method RingBuffer.getMinimumGatingSequence(): long
removed: method RingBuffer.hasAvailableCapacity(int): boolean
removed: method RingBuffer.isPublished(long): boolean
removed: method RingBuffer.newBarrier(Sequence[]): SequenceBarrier
removed: method RingBuffer.newPoller(Sequence[]): EventPoller
removed: method RingBuffer.next(): long
removed: method RingBuffer.next(int): long
removed: method RingBuffer.publish(long): void
removed: method RingBuffer.publish(long, long): void
removed: method RingBuffer.publishEvent(EventTranslator): void
removed: method RingBuffer.publishEvent(EventTranslatorOneArg, Object): void
removed: method RingBuffer.publishEvent(EventTranslatorThreeArg, Object, Object, Object): void
removed: method RingBuffer.publishEvent(EventTranslatorTwoArg, Object, Object): void
removed: method RingBuffer.publishEvent(EventTranslatorVararg, Object[]): void
removed: method RingBuffer.publishEvents(EventTranslatorOneArg, Object[]): void
removed: method RingBuffer.publishEvents(EventTranslatorOneArg, int, int, Object[]): void
removed: method RingBuffer.publishEvents(EventTranslatorThreeArg, Object[], Object[], Object[]): void
removed: method RingBuffer.publishEvents(EventTranslatorThreeArg, int, int, Object[], Object[], Object[]): void
removed: method RingBuffer.publishEvents(EventTranslatorTwoArg, Object[], Object[]): void
removed: method RingBuffer.publishEvents(EventTranslatorTwoArg, int, int, Object[], Object[]): void
removed: method RingBuffer.publishEvents(EventTranslatorVararg, Object[][]): void
removed: method RingBuffer.publishEvents(EventTranslatorVararg, int, int, Object[][]): void
removed: method RingBuffer.publishEvents(EventTranslator[]): void
removed: method RingBuffer.publishEvents(EventTranslator[], int, int): void
removed: method RingBuffer.remainingCapacity(): long
removed: method RingBuffer.removeGatingSequence(Sequence): boolean
removed: method RingBuffer.resetTo(long): void
removed: method RingBuffer.tryNext(): long
removed: method RingBuffer.tryNext(int): long
removed: method RingBuffer.tryPublishEvent(EventTranslator): boolean
removed: method RingBuffer.tryPublishEvent(EventTranslatorOneArg, Object): boolean
removed: method RingBuffer.tryPublishEvent(EventTranslatorThreeArg, Object, Object, Object): boolean
removed: method RingBuffer.tryPublishEvent(EventTranslatorTwoArg, Object, Object): boolean
removed: method RingBuffer.tryPublishEvent(EventTranslatorVararg, Object[]): boolean
removed: method RingBuffer.tryPublishEvents(EventTranslatorOneArg, Object[]): boolean
removed: method RingBuffer.tryPublishEvents(EventTranslatorOneArg, int, int, Object[]): boolean
removed: method RingBuffer.tryPublishEvents(EventTranslatorThreeArg, Object[], Object[], Object[]): boolean
removed: method RingBuffer.tryPublishEvents(EventTranslatorThreeArg, int, int, Object[], Object[], Object[]): boolean
removed: method RingBuffer.tryPublishEvents(EventTranslatorTwoArg, Object[], Object[]): boolean
removed: method RingBuffer.tryPublishEvents(EventTranslatorTwoArg, int, int, Object[], Object[]): boolean
removed: method RingBuffer.tryPublishEvents(EventTranslatorVararg, Object[][]): boolean
removed: method RingBuffer.tryPublishEvents(EventTranslatorVararg, int, int, Object[][]): boolean
removed: method RingBuffer.tryPublishEvents(EventTranslator[]): boolean
removed: method RingBuffer.tryPublishEvents(EventTranslator[], int, int): boolean
removed: method Sequence.addAndGet(long): long
removed: method Sequence.compareAndSet(long, long): boolean
removed: method Sequence.get(): long
removed: method Sequence.incrementAndGet(): long
removed: method Sequence.set(long): void
removed: method Sequence.setVolatile(long): void
removed: method Sequence.toString(): String
removed: method SequenceBarrier.alert(): void
removed: method SequenceBarrier.checkAlert(): void
removed: method SequenceBarrier.clearAlert(): void
removed: method SequenceBarrier.getCursor(): long
removed: method SequenceBarrier.isAlerted(): boolean
removed: method SequenceBarrier.waitFor(long): long
removed: method SequenceGroup.add(Sequence): void
removed: method SequenceGroup.addWhileRunning(Cursored, Sequence): void
removed: method SequenceGroup.get(): long
removed: method SequenceGroup.remove(Sequence): boolean
removed: method SequenceGroup.set(long): void
removed: method SequenceGroup.size(): int
removed: method SequenceReportingEventHandler.setSequenceCallback(Sequence): void
removed: method Sequenced.getBufferSize(): int
removed: method Sequenced.hasAvailableCapacity(int): boolean
removed: method Sequenced.next(): long
removed: method Sequenced.next(int): long
removed: method Sequenced.publish(long): void
removed: method Sequenced.publish(long, long): void
removed: method Sequenced.remainingCapacity(): long
removed: method Sequenced.tryNext(): long
removed: method Sequenced.tryNext(int): long
removed: method Sequencer.addGatingSequences(Sequence[]): void
removed: method Sequencer.claim(long): void
removed: method Sequencer.getHighestPublishedSequence(long, long): long
removed: method Sequencer.getMinimumSequence(): long
removed: method Sequencer.isAvailable(long): boolean
removed: method Sequencer.newBarrier(Sequence[]): SequenceBarrier
removed: method Sequencer.newPoller(DataProvider, Sequence[]): EventPoller
removed: method Sequencer.removeGatingSequence(Sequence): boolean
removed: method SingleProducerSequencer.claim(long): void
removed: method SingleProducerSequencer.getHighestPublishedSequence(long, long): long
removed: method SingleProducerSequencer.hasAvailableCapacity(int): boolean
removed: method SingleProducerSequencer.isAvailable(long): boolean
removed: method SingleProducerSequencer.next(): long
removed: method SingleProducerSequencer.next(int): long
removed: method SingleProducerSequencer.publish(long): void
removed: method SingleProducerSequencer.publish(long, long): void
removed: method SingleProducerSequencer.remainingCapacity(): long
removed: method SingleProducerSequencer.tryNext(): long
removed: method SingleProducerSequencer.tryNext(int): long
removed: method SleepingWaitStrategy.signalAllWhenBlocking(): void
removed: method SleepingWaitStrategy.waitFor(long, Sequence, Sequence, SequenceBarrier): long
removed: method TimeoutBlockingWaitStrategy.signalAllWhenBlocking(): void
removed: method TimeoutBlockingWaitStrategy.waitFor(long, Sequence, Sequence, SequenceBarrier): long
removed: method TimeoutException.fillInStackTrace(): Throwable
removed: method TimeoutHandler.onTimeout(long): void
removed: method WaitStrategy.signalAllWhenBlocking(): void
removed: method WaitStrategy.waitFor(long, Sequence, Sequence, SequenceBarrier): long
removed: method WorkHandler.onEvent(Object): void
removed: method WorkProcessor.getSequence(): Sequence
removed: method WorkProcessor.halt(): void
removed: method WorkProcessor.isRunning(): boolean
removed: method WorkProcessor.run(): void
removed: method WorkerPool.drainAndHalt(): void
removed: method WorkerPool.getWorkerSequences(): Sequence[]
removed: method WorkerPool.halt(): void
removed: method WorkerPool.isRunning(): boolean
removed: method WorkerPool.start(Executor): RingBuffer
removed: method YieldingWaitStrategy.signalAllWhenBlocking(): void
removed: method YieldingWaitStrategy.waitFor(long, Sequence, Sequence, SequenceBarrier): long
removed: static field AlertException.INSTANCE: AlertException
removed: static field EventPoller.PollState.GATING: EventPoller.PollState
removed: static field EventPoller.PollState.IDLE: EventPoller.PollState
removed: static field EventPoller.PollState.PROCESSING: EventPoller.PollState
removed: static field InsufficientCapacityException.INSTANCE: InsufficientCapacityException
removed: static field RingBuffer.INITIAL_CURSOR_VALUE: long
removed: static field Sequencer.INITIAL_CURSOR_VALUE: long
removed: static field TimeoutException.INSTANCE: TimeoutException
removed: static method EventPoller.PollState.valueOf(String): EventPoller.PollState
removed: static method EventPoller.PollState.values(): EventPoller.PollState[]
removed: static method EventPoller.newInstance(DataProvider, Sequencer, Sequence, Sequence, Sequence[]): EventPoller
removed: static method PhasedBackoffWaitStrategy.withLiteLock(long, long, TimeUnit): PhasedBackoffWaitStrategy
removed: static method PhasedBackoffWaitStrategy.withLock(long, long, TimeUnit): PhasedBackoffWaitStrategy
removed: static method PhasedBackoffWaitStrategy.withSleep(long, long, TimeUnit): PhasedBackoffWaitStrategy
removed: static method RingBuffer.create(ProducerType, EventFactory, int, WaitStrategy): RingBuffer
removed: static method RingBuffer.createMultiProducer(EventFactory, int): RingBuffer
removed: static method RingBuffer.createMultiProducer(EventFactory, int, WaitStrategy): RingBuffer
removed: static method RingBuffer.createSingleProducer(EventFactory, int): RingBuffer
removed: static method RingBuffer.createSingleProducer(EventFactory, int, WaitStrategy): RingBuffer

removed: ctor Histogram(long[])
removed: final class Histogram
removed: method Histogram.addObservation(long): boolean
removed: method Histogram.addObservations(Histogram): void
removed: method Histogram.clear(): void
removed: method Histogram.getCount(): long
removed: method Histogram.getCountAt(int): long
removed: method Histogram.getFourNinesUpperBound(): long
removed: method Histogram.getMax(): long
removed: method Histogram.getMean(): BigDecimal
removed: method Histogram.getMin(): long
removed: method Histogram.getSize(): int
removed: method Histogram.getTwoNinesUpperBound(): long
removed: method Histogram.getUpperBoundAt(int): long
removed: method Histogram.getUpperBoundForFactor(double): long
removed: method Histogram.toString(): String

removed: class Disruptor
removed: class EventHandlerGroup
removed: class ExceptionHandlerSetting
removed: ctor Disruptor(EventFactory, int, Executor)
removed: ctor Disruptor(EventFactory, int, Executor, ProducerType, WaitStrategy)
removed: enum ProducerType
removed: interface EventProcessorFactory
removed: method Disruptor.after(EventHandler[]): EventHandlerGroup
removed: method Disruptor.after(EventProcessor[]): EventHandlerGroup
removed: method Disruptor.get(long): Object
removed: method Disruptor.getBarrierFor(EventHandler): SequenceBarrier
removed: method Disruptor.getBufferSize(): long
removed: method Disruptor.getCursor(): long
removed: method Disruptor.getRingBuffer(): RingBuffer
removed: method Disruptor.halt(): void
removed: method Disruptor.handleEventsWith(EventHandler[]): EventHandlerGroup
removed: method Disruptor.handleEventsWith(EventProcessorFactory[]): EventHandlerGroup
removed: method Disruptor.handleEventsWith(EventProcessor[]): EventHandlerGroup
removed: method Disruptor.handleEventsWithWorkerPool(WorkHandler[]): EventHandlerGroup
removed: method Disruptor.handleExceptionsFor(EventHandler): ExceptionHandlerSetting
removed: method Disruptor.handleExceptionsWith(ExceptionHandler): void
removed: method Disruptor.publishEvent(EventTranslator): void
removed: method Disruptor.publishEvent(EventTranslatorOneArg, Object): void
removed: method Disruptor.publishEvents(EventTranslatorOneArg, Object[]): void
removed: method Disruptor.shutdown(): void
removed: method Disruptor.shutdown(long, TimeUnit): void
removed: method Disruptor.start(): RingBuffer
removed: method EventHandlerGroup.and(EventHandlerGroup): EventHandlerGroup
removed: method EventHandlerGroup.and(EventProcessor[]): EventHandlerGroup
removed: method EventHandlerGroup.asSequenceBarrier(): SequenceBarrier
removed: method EventHandlerGroup.handleEventsWith(EventHandler[]): EventHandlerGroup
removed: method EventHandlerGroup.handleEventsWith(EventProcessorFactory[]): EventHandlerGroup
removed: method EventHandlerGroup.handleEventsWithWorkerPool(WorkHandler[]): EventHandlerGroup
removed: method EventHandlerGroup.then(EventHandler[]): EventHandlerGroup
removed: method EventHandlerGroup.then(EventProcessorFactory[]): EventHandlerGroup
removed: method EventHandlerGroup.thenHandleEventsWithWorkerPool(WorkHandler[]): EventHandlerGroup
removed: method EventProcessorFactory.createEventProcessor(RingBuffer, Sequence[]): EventProcessor
removed: method ExceptionHandlerSetting.with(ExceptionHandler): void
removed: static field ProducerType.MULTI: ProducerType
removed: static field ProducerType.SINGLE: ProducerType
removed: static method ProducerType.valueOf(String): ProducerType
removed: static method ProducerType.values(): ProducerType[]

removed: class MutableLong
removed: ctor MutableLong()
removed: ctor MutableLong(long)
removed: ctor PaddedLong()
removed: ctor PaddedLong(long)
removed: ctor Util()
removed: enum DaemonThreadFactory implements ThreadFactory
removed: final class PaddedLong extends MutableLong
removed: final class Util
removed: method DaemonThreadFactory.newThread(Runnable): Thread
removed: method MutableLong.get(): long
removed: method MutableLong.increment(): void
removed: method MutableLong.set(long): void
removed: method PaddedLong.sumPaddingToPreventOptimisation(): long
removed: static field DaemonThreadFactory.INSTANCE: DaemonThreadFactory
removed: static method DaemonThreadFactory.valueOf(String): DaemonThreadFactory
removed: static method DaemonThreadFactory.values(): DaemonThreadFactory[]
removed: static method Util.ceilingNextPowerOfTwo(int): int
removed: static method Util.getAddressFromDirectByteBuffer(ByteBuffer): long
removed: static method Util.getMinimumSequence(Sequence[]): long
removed: static method Util.getMinimumSequence(Sequence[], long): long
removed: static method Util.getSequencesFor(EventProcessor[]): Sequence[]
removed: static method Util.getUnsafe(): Unsafe
removed: static method Util.log2(int): int

added: abstract class Loggers
added: class Metrics
added: ctor Metrics()
added: ctor Metrics.MicrometerConfiguration()
added: interface Logger
added: interface Logger.ChoiceOfMessageSupplier
added: method Logger.ChoiceOfMessageSupplier.get(boolean): String
added: method Logger.debug(String): void
added: method Logger.debug(String, Object[]): void
added: method Logger.debug(String, Throwable): void
added: method Logger.error(String): void
added: method Logger.error(String, Object[]): void
added: method Logger.error(String, Throwable): void
added: method Logger.errorOrDebug(Logger.ChoiceOfMessageSupplier): void
added: method Logger.errorOrDebug(Logger.ChoiceOfMessageSupplier, Throwable): void
added: method Logger.getName(): String
added: method Logger.info(String): void
added: method Logger.info(String, Object[]): void
added: method Logger.info(String, Throwable): void
added: method Logger.infoOrDebug(Logger.ChoiceOfMessageSupplier): void
added: method Logger.infoOrDebug(Logger.ChoiceOfMessageSupplier, Throwable): void
added: method Logger.isDebugEnabled(): boolean
added: method Logger.isErrorEnabled(): boolean
added: method Logger.isInfoEnabled(): boolean
added: method Logger.isTraceEnabled(): boolean
added: method Logger.isWarnEnabled(): boolean
added: method Logger.trace(String): void
added: method Logger.trace(String, Object[]): void
added: method Logger.trace(String, Throwable): void
added: method Logger.warn(String): void
added: method Logger.warn(String, Object[]): void
added: method Logger.warn(String, Throwable): void
added: method Logger.warnOrDebug(Logger.ChoiceOfMessageSupplier): void
added: method Logger.warnOrDebug(Logger.ChoiceOfMessageSupplier, Throwable): void
added: static class Metrics.MicrometerConfiguration
added: static field Loggers.FALLBACK_PROPERTY: String
added: static method Loggers.getLogger(Class): Logger
added: static method Loggers.getLogger(String): Logger
added: static method Loggers.resetLoggerFactory(): void
added: static method Loggers.useConsoleLoggers(): void
added: static method Loggers.useCustomLoggers(Function): void
added: static method Loggers.useJdkLoggers(): void
added: static method Loggers.useSl4jLoggers(): void
added: static method Loggers.useVerboseConsoleLoggers(): void
added: static method Metrics.MicrometerConfiguration.getRegistry(): MeterRegistry
added: static method Metrics.MicrometerConfiguration.useRegistry(MeterRegistry): MeterRegistry
added: static method Metrics.isInstrumentationAvailable(): boolean

added: @interface Incubating
added: @interface NonNull
added: @interface NonNullApi
added: @interface Nullable

added: final class Queues
added: static field Queues.CAPACITY_UNSURE: int
added: static field Queues.SMALL_BUFFER_SIZE: int
added: static field Queues.XS_BUFFER_SIZE: int
added: static method Queues.capacity(Queue): int
added: static method Queues.ceilingNextPowerOfTwo(int): int
added: static method Queues.empty(): Supplier
added: static method Queues.get(int): Supplier
added: static method Queues.isPowerOfTwo(int): boolean
added: static method Queues.one(): Supplier
added: static method Queues.small(): Supplier
added: static method Queues.unbounded(): Supplier
added: static method Queues.unbounded(int): Supplier
added: static method Queues.unboundedMultiproducer(): Supplier
added: static method Queues.xs(): Supplier

added: ctor ReactorContextAccessor()
added: final class ReactorContextAccessor implements ContextAccessor
added: interface Context extends ContextView
added: interface ContextView
added: method Context.delete(Object): Context
added: method Context.put(Object, Object): Context
added: method Context.putAll(Context): Context
added: method Context.putAll(ContextView): Context
added: method Context.putAllMap(Map): Context
added: method Context.putNonNull(Object, Object): Context
added: method Context.readOnly(): ContextView
added: method ContextView.forEach(BiConsumer): void
added: method ContextView.get(Class): Object
added: method ContextView.get(Object): Object
added: method ContextView.getOrDefault(Object, Object): Object
added: method ContextView.getOrEmpty(Object): Optional
added: method ContextView.hasKey(Object): boolean
added: method ContextView.isEmpty(): boolean
added: method ContextView.size(): int
added: method ContextView.stream(): Stream
added: method ReactorContextAccessor.readValue(ContextView, Object): Object
added: method ReactorContextAccessor.readValues(ContextView, Predicate, Map): void
added: method ReactorContextAccessor.readableType(): Class
added: method ReactorContextAccessor.writeValues(Map, Context): Context
added: method ReactorContextAccessor.writeableType(): Class
added: static method Context.empty(): Context
added: static method Context.of(ContextView): Context
added: static method Context.of(Map): Context
added: static method Context.of(Object, Object): Context
added: static method Context.of(Object, Object, Object, Object): Context
added: static method Context.of(Object, Object, Object, Object, Object, Object): Context
added: static method Context.of(Object, Object, Object, Object, Object, Object, Object, Object): Context
added: static method Context.of(Object, Object, Object, Object, Object, Object, Object, Object, Object, Object): Context

added: abstract class Tuples implements Function
added: class Tuple2 implements Iterable, Serializable
added: class Tuple3 extends Tuple2
added: class Tuple4 extends Tuple3
added: class Tuple5 extends Tuple4
added: class Tuple6 extends Tuple5
added: class Tuple7 extends Tuple6
added: class Tuple8 extends Tuple7
added: method Tuple2.equals(Object): boolean
added: method Tuple2.get(int): Object
added: method Tuple2.getT1(): Object
added: method Tuple2.getT2(): Object
added: method Tuple2.hashCode(): int
added: method Tuple2.iterator(): Iterator
added: method Tuple2.mapT1(Function): Tuple2
added: method Tuple2.mapT2(Function): Tuple2
added: method Tuple2.size(): int
added: method Tuple2.toArray(): Object[]
added: method Tuple2.toList(): List
added: method Tuple2.toString(): String
added: method Tuple3.equals(Object): boolean
added: method Tuple3.get(int): Object
added: method Tuple3.getT3(): Object
added: method Tuple3.hashCode(): int
added: method Tuple3.mapT1(Function): Tuple3
added: method Tuple3.mapT2(Function): Tuple3
added: method Tuple3.mapT3(Function): Tuple3
added: method Tuple3.size(): int
added: method Tuple3.toArray(): Object[]
added: method Tuple4.equals(Object): boolean
added: method Tuple4.get(int): Object
added: method Tuple4.getT4(): Object
added: method Tuple4.hashCode(): int
added: method Tuple4.mapT1(Function): Tuple4
added: method Tuple4.mapT2(Function): Tuple4
added: method Tuple4.mapT3(Function): Tuple4
added: method Tuple4.mapT4(Function): Tuple4
added: method Tuple4.size(): int
added: method Tuple4.toArray(): Object[]
added: method Tuple5.equals(Object): boolean
added: method Tuple5.get(int): Object
added: method Tuple5.getT5(): Object
added: method Tuple5.hashCode(): int
added: method Tuple5.mapT1(Function): Tuple5
added: method Tuple5.mapT2(Function): Tuple5
added: method Tuple5.mapT3(Function): Tuple5
added: method Tuple5.mapT4(Function): Tuple5
added: method Tuple5.mapT5(Function): Tuple5
added: method Tuple5.size(): int
added: method Tuple5.toArray(): Object[]
added: method Tuple6.equals(Object): boolean
added: method Tuple6.get(int): Object
added: method Tuple6.getT6(): Object
added: method Tuple6.hashCode(): int
added: method Tuple6.mapT1(Function): Tuple6
added: method Tuple6.mapT2(Function): Tuple6
added: method Tuple6.mapT3(Function): Tuple6
added: method Tuple6.mapT4(Function): Tuple6
added: method Tuple6.mapT5(Function): Tuple6
added: method Tuple6.mapT6(Function): Tuple6
added: method Tuple6.size(): int
added: method Tuple6.toArray(): Object[]
added: method Tuple7.equals(Object): boolean
added: method Tuple7.get(int): Object
added: method Tuple7.getT7(): Object
added: method Tuple7.hashCode(): int
added: method Tuple7.mapT1(Function): Tuple7
added: method Tuple7.mapT2(Function): Tuple7
added: method Tuple7.mapT3(Function): Tuple7
added: method Tuple7.mapT4(Function): Tuple7
added: method Tuple7.mapT5(Function): Tuple7
added: method Tuple7.mapT6(Function): Tuple7
added: method Tuple7.mapT7(Function): Tuple7
added: method Tuple7.size(): int
added: method Tuple7.toArray(): Object[]
added: method Tuple8.equals(Object): boolean
added: method Tuple8.get(int): Object
added: method Tuple8.getT8(): Object
added: method Tuple8.hashCode(): int
added: method Tuple8.mapT1(Function): Tuple8
added: method Tuple8.mapT2(Function): Tuple8
added: method Tuple8.mapT3(Function): Tuple8
added: method Tuple8.mapT4(Function): Tuple8
added: method Tuple8.mapT5(Function): Tuple8
added: method Tuple8.mapT6(Function): Tuple8
added: method Tuple8.mapT7(Function): Tuple8
added: method Tuple8.mapT8(Function): Tuple8
added: method Tuple8.size(): int
added: method Tuple8.toArray(): Object[]
added: method Tuples.apply(Object): Tuple2
added: static method Tuples.fn2(): Function
added: static method Tuples.fn3(): Function
added: static method Tuples.fn3(Function): Function
added: static method Tuples.fn4(): Function
added: static method Tuples.fn4(Function): Function
added: static method Tuples.fn5(): Function
added: static method Tuples.fn5(Function): Function
added: static method Tuples.fn6(): Function
added: static method Tuples.fn6(Function): Function
added: static method Tuples.fn7(): Function
added: static method Tuples.fn7(Function): Function
added: static method Tuples.fn8(): Function
added: static method Tuples.fn8(Function): Function
added: static method Tuples.fnAny(): Function
added: static method Tuples.fnAny(Function): Function
added: static method Tuples.fromArray(Object[]): Tuple2
added: static method Tuples.of(Object, Object): Tuple2
added: static method Tuples.of(Object, Object, Object): Tuple3
added: static method Tuples.of(Object, Object, Object, Object): Tuple4
added: static method Tuples.of(Object, Object, Object, Object, Object): Tuple5
added: static method Tuples.of(Object, Object, Object, Object, Object, Object): Tuple6
added: static method Tuples.of(Object, Object, Object, Object, Object, Object, Object): Tuple7
added: static method Tuples.of(Object, Object, Object, Object, Object, Object, Object, Object): Tuple8

added: final class RepeatSpec implements Function
added: interface RepeatSpec.RepeatSignal
added: method RepeatSpec.RepeatSignal.backoff(): Duration
added: method RepeatSpec.RepeatSignal.companionValue(): Long
added: method RepeatSpec.RepeatSignal.copy(): RepeatSpec.RepeatSignal
added: method RepeatSpec.RepeatSignal.iteration(): long
added: method RepeatSpec.RepeatSignal.repeatContextView(): ContextView
added: method RepeatSpec.apply(Flux): Publisher
added: method RepeatSpec.doAfterRepeat(Consumer): RepeatSpec
added: method RepeatSpec.doBeforeRepeat(Consumer): RepeatSpec
added: method RepeatSpec.generateCompanion(Flux): Publisher
added: method RepeatSpec.jitter(double): RepeatSpec
added: method RepeatSpec.onlyIf(Predicate): RepeatSpec
added: method RepeatSpec.withFixedDelay(Duration): RepeatSpec
added: method RepeatSpec.withRepeatContext(ContextView): RepeatSpec
added: method RepeatSpec.withScheduler(Scheduler): RepeatSpec
added: static method RepeatSpec.create(Predicate, long): RepeatSpec
added: static method RepeatSpec.once(): RepeatSpec
added: static method RepeatSpec.times(long): RepeatSpec

added: abstract class Retry
added: ctor Retry()
added: ctor Retry(ContextView)
added: field Retry.retryContext: ContextView
added: field RetryBackoffSpec.backoffSchedulerSupplier: Supplier
added: field RetryBackoffSpec.errorFilter: Predicate
added: field RetryBackoffSpec.isTransientErrors: boolean
added: field RetryBackoffSpec.jitterFactor: double
added: field RetryBackoffSpec.maxAttempts: long
added: field RetryBackoffSpec.maxBackoff: Duration
added: field RetryBackoffSpec.minBackoff: Duration
added: field RetryBackoffSpec.multiplier: double
added: field RetrySpec.errorFilter: Predicate
added: field RetrySpec.isTransientErrors: boolean
added: field RetrySpec.maxAttempts: long
added: final class RetryBackoffSpec extends Retry
added: final class RetrySpec extends Retry
added: interface Retry.RetrySignal
added: method Retry.RetrySignal.copy(): Retry.RetrySignal
added: method Retry.RetrySignal.failure(): Throwable
added: method Retry.RetrySignal.retryContextView(): ContextView
added: method Retry.RetrySignal.totalRetries(): long
added: method Retry.RetrySignal.totalRetriesInARow(): long
added: method Retry.generateCompanion(Flux): Publisher
added: method Retry.retryContext(): ContextView
added: method RetryBackoffSpec.doAfterRetry(Consumer): RetryBackoffSpec
added: method RetryBackoffSpec.doAfterRetryAsync(Function): RetryBackoffSpec
added: method RetryBackoffSpec.doBeforeRetry(Consumer): RetryBackoffSpec
added: method RetryBackoffSpec.doBeforeRetryAsync(Function): RetryBackoffSpec
added: method RetryBackoffSpec.filter(Predicate): RetryBackoffSpec
added: method RetryBackoffSpec.generateCompanion(Flux): Flux
added: method RetryBackoffSpec.jitter(double): RetryBackoffSpec
added: method RetryBackoffSpec.maxAttempts(long): RetryBackoffSpec
added: method RetryBackoffSpec.maxBackoff(Duration): RetryBackoffSpec
added: method RetryBackoffSpec.minBackoff(Duration): RetryBackoffSpec
added: method RetryBackoffSpec.modifyErrorFilter(Function): RetryBackoffSpec
added: method RetryBackoffSpec.multiplier(double): RetryBackoffSpec
added: method RetryBackoffSpec.onRetryExhaustedThrow(BiFunction): RetryBackoffSpec
added: method RetryBackoffSpec.scheduler(Scheduler): RetryBackoffSpec
added: method RetryBackoffSpec.transientErrors(boolean): RetryBackoffSpec
added: method RetryBackoffSpec.validateArguments(): void
added: method RetryBackoffSpec.withRetryContext(ContextView): RetryBackoffSpec
added: method RetrySpec.doAfterRetry(Consumer): RetrySpec
added: method RetrySpec.doAfterRetryAsync(Function): RetrySpec
added: method RetrySpec.doBeforeRetry(Consumer): RetrySpec
added: method RetrySpec.doBeforeRetryAsync(Function): RetrySpec
added: method RetrySpec.filter(Predicate): RetrySpec
added: method RetrySpec.generateCompanion(Flux): Flux
added: method RetrySpec.maxAttempts(long): RetrySpec
added: method RetrySpec.modifyErrorFilter(Function): RetrySpec
added: method RetrySpec.onRetryExhaustedThrow(BiFunction): RetrySpec
added: method RetrySpec.transientErrors(boolean): RetrySpec
added: method RetrySpec.withRetryContext(ContextView): RetrySpec
added: static method Retry.backoff(long, Duration): RetryBackoffSpec
added: static method Retry.fixedDelay(long, Duration): RetryBackoffSpec
added: static method Retry.from(Function): Retry
added: static method Retry.indefinitely(): RetrySpec
added: static method Retry.max(long): RetrySpec
added: static method Retry.maxInARow(long): RetrySpec
added: static method Retry.withThrowable(Function): Retry