@ParametersAreNonnullByDefault
See: Description
| Class | Description |
|---|---|
| BaseDuplexConnection | |
| BitUtil |
Miscellaneous useful functions for dealing with low level bits and bytes.
|
| ClientServerInputMultiplexer |
DuplexConnection.receive() is a single stream on which the following type of frames
arrive:
Frames for streams initiated by the initiator of the connection (client). |
| CollectionUtil |
Utility functions for collection objects.
|
| Hashing |
Hashing functions for applying to integers.
|
| LimitableRequestPublisher<T> | |
| SwitchTransformFlux<T,R> | Deprecated
in favour of
Flux.switchOnFirst(BiFunction) |
| SynchronizedIntObjectHashMap<V> |
A hash map implementation of
IntObjectMap that uses open addressing for keys. |
| UnboundedProcessor<T> |
A Processor implementation that takes a custom queue and allows only a single subscriber.
|
| UnicastMonoEmpty |
Represents an empty publisher which only calls onSubscribe and onComplete and allows only a
single subscriber.
|
| UnicastMonoProcessor<O> |