Dependencies
Declarations
-
reactor
- adapter
-
core
- CorePublisher
- CoreSubscriber
- Disposable
-
Disposables
- Disposables(): void
- composite(): Composite
- composite(Disposable[]): Composite
- composite(Iterable<Disposable>): Composite
- disposed(): Disposable
- never(): Disposable
- single(): Disposable
- swap(): Swap
- ListCompositeDisposable
- SwapDisposable
- SimpleDisposable
- AlwaysDisposable
- NeverDisposable
- DISPOSED: Disposable
- set(AtomicReferenceFieldUpdater<Object, Disposable>, Object, Disposable): boolean
- replace(AtomicReferenceFieldUpdater<Object, Disposable>, Object, Disposable): boolean
- dispose(AtomicReferenceFieldUpdater<Object, Disposable>, Object): boolean
- isDisposed(Disposable): boolean
-
Exceptions
- failWithCancel(): RuntimeException
- failWithOverflow(): IllegalStateException
- BACKPRESSURE_ERROR_QUEUE_FULL: String
- TERMINATED: Throwable
- addThrowable(AtomicReferenceFieldUpdater<Object, Throwable>, Object, Throwable): boolean
- multiple(Throwable[]): RuntimeException
- multiple(Iterable<Throwable>): RuntimeException
- bubble(Throwable): RuntimeException
- duplicateOnSubscribeException(): IllegalStateException
- errorCallbackNotImplemented(Throwable): UnsupportedOperationException
- failWithOverflow(String): IllegalStateException
- failWithRejected(): RejectedExecutionException
- failWithRejectedNotTimeCapable(): RejectedExecutionException
- failWithRejected(Throwable): RejectedExecutionException
- failWithRejected(String): RejectedExecutionException
- retryExhausted(String, Throwable): RuntimeException
- isOverflow(Throwable): boolean
- isBubbling(Throwable): boolean
- isCancel(Throwable): boolean
- isErrorCallbackNotImplemented(Throwable): boolean
- isMultiple(Throwable): boolean
- isRetryExhausted(Throwable): boolean
- isTraceback(Throwable): boolean
- nullOrNegativeRequestException(long): IllegalArgumentException
- propagate(Throwable): RuntimeException
- terminate(AtomicReferenceFieldUpdater<Object, Throwable>, Object): Throwable
- throwIfFatal(Throwable): void
- throwIfJvmFatal(Throwable): void
- unwrap(Throwable): Throwable
- unwrapMultiple(Throwable): List<Throwable>
- unwrapMultipleExcludingTracebacks(Throwable): List<Throwable>
- addSuppressed(RuntimeException, Throwable): RuntimeException
- addSuppressed(Throwable, Throwable): Throwable
- Exceptions(): void
- REJECTED_EXECUTION: RejectedExecutionException
- NOT_TIME_CAPABLE_REJECTED_EXECUTION: RejectedExecutionException
- CompositeException
- BubblingException
- ReactiveException
- ErrorCallbackNotImplemented
- CancelException
- OverflowException
- RetryExhaustedException
- ReactorRejectedExecutionException
- StaticRejectedExecutionException
- StaticThrowable
- Fuseable
-
Scannable
- OPERATOR_NAME_UNRELATED_WORDS_PATTERN: Pattern
- Attr
- from(Object): Scannable
- actuals(): Stream<Scannable>
- inners(): Stream<Scannable>
- isScanAvailable(): boolean
- name(): String
- stepName(): String
- steps(): Stream<String>
- parents(): Stream<Scannable>
- scanUnsafe(Attr): Object
- scan(Attr<Object>): Object
- scanOrDefault(Attr<Object>, Object): Object
- tags(): Stream<Tuple2<String, String>>
-
publisher
- BaseSubscriber
- BlockingFirstSubscriber
- BlockingIterable
- BlockingLastSubscriber
- BlockingMonoSubscriber
- BlockingOptionalMonoSubscriber
- BlockingSingleSubscriber
- BufferOverflowStrategy
- ConnectableFlux
- ConnectableFluxHide
- ConnectableFluxOnAssembly
- ConnectableLift
- ConnectableLiftFuseable
- ContextHolder
- ContextTrackingFunctionWrapper
- DelegateProcessor
- DirectInnerContainer
- DirectProcessor
- DrainUtils
- EmitterProcessor
- Flux
- FluxArray
- FluxAutoConnect
- FluxAutoConnectFuseable
- FluxBuffer
- FluxBufferBoundary
- FluxBufferPredicate
- FluxBufferTimeout
- FluxBufferWhen
- FluxCallable
- FluxCallableOnAssembly
- FluxCancelOn
- FluxCombineLatest
- FluxConcatArray
- FluxConcatIterable
- FluxConcatMap
- FluxConcatMapNoPrefetch
- FluxContextWrite
- FluxCreate
- FluxDefaultIfEmpty
- FluxDefer
- FluxDeferContextual
- FluxDelaySequence
- FluxDelaySubscription
- FluxDematerialize
- FluxDetach
- FluxDistinct
- FluxDistinctFuseable
- FluxDistinctUntilChanged
- FluxDoFinally
- FluxDoFinallyFuseable
- FluxDoFirst
- FluxDoFirstFuseable
- FluxDoOnEach
- FluxDoOnEachFuseable
- FluxElapsed
- FluxEmpty
- FluxError
- FluxErrorOnRequest
- FluxErrorSupplied
- FluxExpand
- FluxFilter
- FluxFilterFuseable
- FluxFilterWhen
- FluxFirstWithSignal
- FluxFirstWithValue
- FluxFlatMap
- FlatMapTracker
- FluxFlattenIterable
- FluxFromMonoOperator
- FluxGenerate
- FluxGroupBy
- FluxGroupJoin
- FluxHandle
- FluxHandleFuseable
- FluxHide
- FluxIndex
- FluxIndexFuseable
- FluxInterval
- FluxIterable
- FluxJoin
- FluxJust
- FluxLift
- FluxLiftFuseable
- FluxLimitRequest
- FluxLog
- FluxLogFuseable
- FluxMap
- FluxMapFuseable
- FluxMapSignal
- FluxMaterialize
- FluxMerge
- FluxMergeOrdered
- FluxMergeSequential
- FluxMetrics
- FluxMetricsFuseable
- FluxName
- FluxNameFuseable
- FluxNever
- FluxOnAssembly
- AssemblyOp
- FluxOnBackpressureBuffer
- FluxOnBackpressureBufferStrategy
- FluxOnBackpressureBufferTimeout
- FluxOnBackpressureDrop
- FluxOnBackpressureLatest
- FluxOnErrorResume
- FluxOperator
- FluxPeek
- FluxPeekFuseable
- FluxProcessor
- FluxPublish
- FluxPublishMulticast
- FluxPublishOn
- FluxRange
- FluxRefCount
- FluxRefCountGrace
- FluxRepeat
- FluxRepeatPredicate
- FluxRepeatWhen
- FluxReplay
- FluxRetry
- FluxRetryWhen
- FluxSample
- FluxSampleFirst
- FluxSampleTimeout
- FluxScan
- FluxScanSeed
- FluxSink
- FluxSkip
- FluxSkipLast
- FluxSkipUntil
- FluxSkipUntilOther
- FluxSkipWhile
- FluxSource
- FluxSourceFuseable
- FluxSourceMono
- FluxSourceMonoFuseable
- FluxStream
- FluxSubscribeOn
- FluxSubscribeOnCallable
- FluxSubscribeOnValue
- FluxSwitchIfEmpty
- FluxSwitchMap
- FluxSwitchOnFirst
- FluxTake
- FluxTakeFuseable
- FluxTakeLast
- FluxTakeLastOne
- FluxTakeUntil
- FluxTakeUntilOther
- FluxTakeWhile
- FluxTimed
- FluxTimeout
- FluxUsing
- FluxUsingWhen
- FluxWindow
- FluxWindowBoundary
- FluxWindowPredicate
- FluxWindowTimeout
- FluxWindowWhen
- FluxWithLatestFrom
- FluxZip
- FluxZipIterable
- GroupedFlux
- GroupedLift
- GroupedLiftFuseable
- Hooks
- ImmutableSignal
- InnerConsumer
- InnerOperator
- InnerProducer
- InternalConnectableFluxOperator
- InternalEmptySink
- InternalFluxOperator
- InternalManySink
- InternalMonoOperator
- InternalOneSink
- LambdaMonoSubscriber
- LambdaSubscriber
- Mono
- MonoAll
- MonoAny
- MonoBridges
- MonoCacheTime
- MonoCallable
- MonoCallableOnAssembly
- MonoCancelOn
- MonoCollect
- MonoCollectList
- MonoCompletionStage
- MonoContextWrite
- MonoCount
- MonoCreate
- MonoCurrentContext
- MonoDefaultIfEmpty
- MonoDefer
- MonoDeferContextual
- MonoDelay
- MonoDelayElement
- MonoDelaySubscription
- MonoDelayUntil
- MonoDematerialize
- MonoDetach
- MonoDoFinally
- MonoDoFinallyFuseable
- MonoDoFirst
- MonoDoFirstFuseable
- MonoDoOnEach
- MonoDoOnEachFuseable
- MonoElapsed
- MonoElementAt
- MonoEmpty
- MonoError
- MonoErrorSupplied
- MonoExpand
- MonoFilter
- MonoFilterFuseable
- MonoFilterWhen
- MonoFirstWithSignal
- MonoFirstWithValue
- MonoFlatMap
- MonoFlatMapMany
- MonoFlattenIterable
- MonoFromFluxOperator
- MonoFromPublisher
- MonoHandle
- MonoHandleFuseable
- MonoHasElement
- MonoHasElements
- MonoHide
- MonoIgnoreElement
- MonoIgnoreElements
- MonoIgnorePublisher
- MonoIgnoreThen
- MonoJust
- MonoLift
- MonoLiftFuseable
- MonoLog
- MonoLogFuseable
- MonoMap
- MonoMapFuseable
- MonoMaterialize
- MonoMetrics
- MonoMetricsFuseable
- MonoName
- MonoNameFuseable
- MonoNever
- MonoNext
- MonoOnAssembly
- MonoOnErrorResume
- MonoOperator
- MonoPeek
- MonoPeekFuseable
- MonoPeekTerminal
- MonoProcessor
- MonoPublishMulticast
- MonoPublishOn
- MonoReduce
- MonoReduceSeed
- MonoRepeat
- MonoRepeatPredicate
- MonoRepeatWhen
- MonoRetry
- MonoRetryWhen
- MonoRunnable
- MonoSequenceEqual
- MonoSingle
- MonoSingleMono
- MonoSink
- MonoSource
- MonoSourceFlux
- MonoSourceFluxFuseable
- MonoSourceFuseable
- MonoStreamCollector
- MonoSubscribeOn
- MonoSubscribeOnCallable
- MonoSubscribeOnValue
- MonoSupplier
- MonoSwitchIfEmpty
- MonoTakeLastOne
- MonoTakeUntilOther
- MonoTimed
- MonoTimeout
- MonoToCompletableFuture
- MonoUsing
- MonoUsingWhen
- MonoWhen
- MonoZip
- NextProcessor
- OnNextFailureStrategy
- OperatorDisposables
- Operators
- OptimizableOperator
- ParallelArraySource
- ParallelCollect
- ParallelConcatMap
- ParallelDoOnEach
- ParallelFilter
- ParallelFlatMap
- ParallelFlux
- ParallelFluxHide
- ParallelFluxName
- ParallelFluxOnAssembly
- ParallelGroup
- ParallelLift
- ParallelLiftFuseable
- ParallelLog
- ParallelMap
- ParallelMergeOrdered
- ParallelMergeReduce
- ParallelMergeSequential
- ParallelMergeSort
- ParallelPeek
- ParallelReduceSeed
- ParallelRunOn
- ParallelSource
- ParallelThen
- QueueDrainSubscriber
- QueueDrainSubscriberPad0
- QueueDrainSubscriberWip
- QueueDrainSubscriberPad2
- QueueDrainSubscriberPad3
- QueueDrainSubscriberPad4
- ReplayProcessor
- SerializedSubscriber
- Signal
- SignalLogger
- SignalPeek
- SignalType
- SinkEmptyMulticast
- SinkEmptySerialized
- SinkManyBestEffort
- SinkManySerialized
- SinkOneSerialized
- Sinks
- SinksSpecs
- SourceProducer
- StrictSubscriber
- SynchronousSink
- Timed
- Traces
- UnicastManySinkNoBackpressure
- UnicastProcessor
-
scheduler
- BoundedElasticScheduler
- DelegateServiceScheduler
- DelegatingScheduledExecutorService
- ElasticScheduler
- EmptyCompositeDisposable
- ExecutorScheduler
- ExecutorServiceWorker
- ImmediateScheduler
- InstantPeriodicWorkerTask
- NonBlocking
- ParallelScheduler
- PeriodicSchedulerTask
- PeriodicWorkerTask
- ReactorBlockHoundIntegration
- ReactorThreadFactory
- Scheduler
- SchedulerMetricDecorator
- SchedulerTask
- Schedulers
- SingleScheduler
- SingleWorkerScheduler
- WorkerTask
-
util
-
Logger
- isTraceEnabled(): boolean
- getName(): String
- trace(String): void
- trace(String, Object[]): void
- trace(String, Throwable): void
- isDebugEnabled(): boolean
- debug(String): void
- debug(String, Object[]): void
- debug(String, Throwable): void
- isInfoEnabled(): boolean
- info(String): void
- info(String, Object[]): void
- info(String, Throwable): void
- isWarnEnabled(): boolean
- warn(String): void
- warn(String, Object[]): void
- warn(String, Throwable): void
- isErrorEnabled(): boolean
- error(String): void
- error(String, Object[]): void
- error(String, Throwable): void
-
Loggers
- FALLBACK_PROPERTY: String
- LOGGER_FACTORY: Function<String, Logger>
- static class initializer
- resetLoggerFactory(): void
- isFallbackToJdk(): boolean
- useConsoleLoggers(): void
- useVerboseConsoleLoggers(): void
- useCustomLoggers(Function<String, Logger>): void
- useJdkLoggers(): void
- useSl4jLoggers(): void
- getLogger(String): Logger
- getLogger(Class<Object>): Logger
- Slf4JLoggerFactory
- Slf4JLogger
- JdkLogger
- JdkLoggerFactory
- ConsoleLogger
- ConsoleLoggerFactory
- Loggers(): void
- Metrics
- annotation
- concurrent
- context
- function
- retry
-
Logger