| Package | Description |
|---|---|
| reactor.rx |
Streams are reactive components derived from Reactive Extensions and implementing Reactive Streams specification.
|
| reactor.rx.action.pair | |
| reactor.rx.stream | |
| reactor.rx.stream.io |
Stream implementations that provide for IO access, for instance read/read-write persisting streams |
| Class and Description |
|---|
| GroupedStream
The Stream will complete or fail whever the parent groupBy action terminates itself.
|
| MapStream
A SubscribableMap is an event-driven Map that signals logged operations to its subscribers.
|
| MapStream.Signal |
| Class and Description |
|---|
| MapStream
A SubscribableMap is an event-driven Map that signals logged operations to its subscribers.
|
| MapStream.Signal |
| Class and Description |
|---|
| MapStream.Operation |
| MapStream.Signal |
| SingleValueStream
A Stream that emits only one value and then complete.
|
| Class and Description |
|---|
| MapStream
A SubscribableMap is an event-driven Map that signals logged operations to its subscribers.
|
| MapStream.Signal |
Copyright © 2016. All rights reserved.