请参阅: 说明
| 接口 | 说明 |
|---|---|
| CorePublisher<T> |
A
CoreSubscriber aware publisher. |
| CoreSubscriber<T> |
A
Context aware subscriber which has relaxed rules for §1.3 and §3.9
compared to the original Subscriber from Reactive Streams. |
| Disposable |
Indicates that a task or resource can be cancelled/disposed.
|
| Disposable.Composite |
A container of
Disposable that is itself Disposable. |
| Disposable.Swap |
A
Disposable container that allows updating/replacing its inner Disposable
atomically and with respect of disposing the container itself. |
| Fuseable |
A micro API for stream fusion, in particular marks producers that support a
Fuseable.QueueSubscription. |
| Fuseable.ConditionalSubscriber<T> |
A subscriber variant that can immediately tell if it consumed
the value or not, directly allowing a new value to be sent if
it didn't.
|
| Fuseable.QueueSubscription<T> |
Support contract for queue-fusion based optimizations on subscriptions.
|
| Fuseable.ScalarCallable<T> |
Marker interface indicating that the target can return a value or null,
otherwise fail immediately and thus a viable target for assembly-time
optimizations.
|
| Fuseable.SynchronousSubscription<T> |
Base class for synchronous sources which have fixed size and can
emit their items in a pull fashion, thus avoiding the request-accounting
overhead in many cases.
|
| Scannable |
A Scannable component exposes state in a non strictly memory consistent way and
results should be understood as best-effort hint of the underlying state.
|
| 类 | 说明 |
|---|---|
| CompositeDisposableHashcodeBenchmark |
See https://github.com/reactor/reactor-core/issues/1237
|
| CoreTest | |
| Disposables |
A support class that offers factory methods for implementations of the specialized
Disposable sub-interfaces (Disposable.Composite,
Disposable.Swap). |
| DisposablesTest | |
| DisposableTest | |
| Exceptions |
Global Reactor Core Exception handling and utils to operate on.
|
| ExceptionsTest | |
| ListCompositeDisposableTest | |
| Scannable.Attr<T> |
Base class for
Scannable attributes, which all can define a meaningful
default. |
| ScannableTest | |
| SwapDisposableTest | |
| TestLoggerExtension |
A JUnit5 extension that installs a
TestLogger as the capturing instance via LoggerUtils.enableCaptureWith(Logger),
disable capture at the end of the test and injects the TestLogger
into the test case (by implementing ParameterResolver). |
| 枚举 | 说明 |
|---|---|
| Scannable.Attr.RunStyle |
An
Enum enumerating the different styles an operator can run : their Enum.ordinal() reflects the level of confidence
in their running mode |
| 异常错误 | 说明 |
|---|---|
| Exceptions.SourceException |
A
Throwable that wraps the actual cause delivered via
Subscriber.onError(Throwable) in case of
Publishers that themselves emit items of type
Publisher. |
| 注释类型 | 说明 |
|---|---|
| TestLoggerExtension.Capture |
Set up a default
TestLoggerExtension, unless @TestLoggerExtension.Redirect annotation is also present. |
| TestLoggerExtension.Redirect |
Set up a
TestLoggerExtension that routes log messages only to the injected TestLogger,
suppressing the logs from the original logger. |