See: Description
Class | Description |
---|---|
BiStreams |
A Streams add-on to work with key/value pairs hydrated in
Tuple2 . |
IOStreams |
A Streams add-on to work with IO components such as ChronicleStreams.
|
Promise<O> |
A
Promise is a stateful event container that accepts a single value or error. |
Promises |
Helper methods for creating
Promise instances. |
Stream<O> |
Base class for components designed to provide a succinct API for working with future values.
|
Streams |
A public factory to build
Stream , Streams provide for common transformations from a few structures such as
Iterable or Future to a Stream, in addition to provide for combinatory operations (merge, switchOnNext...). |
StreamUtils |
A simple collection of utils to assist in various tasks such as Debugging
|
StreamUtils.StreamVisitor |
Enum | Description |
---|---|
Promise.FinalState |
Signal
rather than by using reactor.bus.selector.Selector Selectors
and reactor.bus.EventBus Reactors directly.Copyright © 2017. All rights reserved.