Search Java Classes and Packages
#Reactor.rx.stream Classes and Interfaces - 22 results found.
| Name | Description | Type | Package | Framework |
| BarrierStream | A BarrierStream provides a type of Stream into which you can bind Consumers and Functions from arbitrary components. | Class | reactor.rx.stream | Reactor |
| ChronicleReaderStream | queue tasks to execute. | Class | reactor.rx.stream.io | Reactor |
| ChronicleStream | Class | reactor.rx.stream.io | Reactor | |
| DeferredStream | A Publisher supplier that will call the passed supplier on each subscribe call. | Class | reactor.rx.stream | Reactor |
| ErrorStream | A Stream that emits a sigle error signal. | Class | reactor.rx.stream | Reactor |
| FutureStream | A Stream that emits a result of a Future and then complete. | Class | reactor.rx.stream | Reactor |
| GroupedStream | The Stream will complete or fail whever the parent groupBy action terminates itself. | Class | reactor.rx.stream | Reactor |
| IterableStream | A Stream that emits Iterable values one by one and then complete. | Class | reactor.rx.stream | Reactor |
| LiftStream | A Stream wrapper that defers a parent stream subscription to the child action subscribe() call. | Class | reactor.rx.stream | Reactor |
| MapStream | A SubscribableMap is an event-driven Map that signals logged operations to its subscribers. | Class | reactor.rx.stream | Reactor |
| MapStream .MutableSignal | Class | reactor.rx.stream | Reactor | |
| MapStream .Operation | Returns the enum constant of this type with the specified name. | Class | reactor.rx.stream | Reactor |
| MapStream .Signal | Class | reactor.rx.stream | Reactor | |
| PeriodicTimerStream | A Stream that emits 0 after an initial delay and ever incrementing long counter if the period argument is The TimerStream will manage dedicated timers for new subscriber assigned via | Class | reactor.rx.stream | Reactor |
| PublisherStream | A Publisher wrapper that takes care of lazy subscribing. | Class | reactor.rx.stream | Reactor |
| RangeStream | A Stream that emits N Long from the inclusive start value defined to the inclusive end and then Since the stream retains the boundaries in a final field, any Subscriber | Class | reactor.rx.stream | Reactor |
| SingleTimerStream | A Stream that emits 0 after an initial delay and then complete The SingleTimerStream will manage dedicated timers for new subscriber assigned via | Class | reactor.rx.stream | Reactor |
| SingleValueStream | A Stream that emits only one value and then complete. | Class | reactor.rx.stream | Reactor |
| 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. | Class | reactor.rx | Reactor |
| StreamUtils | A simple collection of utils to assist in various tasks such as DebuggingSince:1. | Class | reactor.rx | Reactor |
| StreamUtils .StreamVisitor | Class | reactor.rx | Reactor | |
| SupplierStream | A Stream that returns the result from Supplier. | Class | reactor.rx.stream | Reactor |