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.