| Class | Description |
|---|---|
| Future<T> |
A Wrapper around CompletableFuture that implements cyclops2-react interfaces and provides a more standard api
e.g.
|
| Future.Instances |
Companion class for creating Type Class instances for working with Futures
|
| LazyReact |
Builder class for LazyFutureStreams
Confgure
Executors
Parallelism / concurrent tasks
Caching
Object pooling
|
| Pipes<K,V> |
Pipes : Stores and manages cyclops2-react Adapters for cross-thread communication
Connected Streams will not be able to complete collect or reduce style methods unless the underlying Adapter for data transfer is closed.
|
| QueueFactories |
Methods for generating QueueFactories for plumbing Streams together
|
| SimpleReact |
Builder class for SimpleReact Stream types
SimpleReact streams are finite eager parallel Streams with a concise API.
|