| Package | Description |
|---|---|
| reactor.groovy.config | |
| reactor.groovy.ext | |
| reactor.rx |
Streams are reactive components derived from Reactive Extensions and implementing Reactive Streams specification.
|
| reactor.rx.action |
Actions are Reactive Streams components derived from Reactive Extensions and beyond.
|
| reactor.rx.action.aggregation | |
| reactor.rx.action.combination | |
| reactor.rx.action.conditional | |
| reactor.rx.action.control | |
| reactor.rx.action.error | |
| reactor.rx.action.filter | |
| reactor.rx.action.metrics | |
| reactor.rx.action.pair | |
| reactor.rx.action.passive | |
| reactor.rx.action.support | |
| reactor.rx.action.terminal | |
| reactor.rx.action.transformation | |
| reactor.rx.broadcast |
Broadcasters are akin to Reactive Extensions Subject.
|
| reactor.rx.stream |
| Class and Description |
|---|
| Action
An Action is a reactive component to subscribe to a
Publisher and in particular
to a Stream. |
| Class and Description |
|---|
| Control
An interface generally associated with a
Stream terminal action such as
Stream.consume(reactor.fn.Consumer) |
| Class and Description |
|---|
| Action
An Action is a reactive component to subscribe to a
Publisher and in particular
to a Stream. |
| CompositeAction
Create a Processor where a given head/tail couple is provided as a Stream (Input upstream) and Action (Output
downstream).
|
| Control
An interface generally associated with a
Stream terminal action such as
Stream.consume(reactor.fn.Consumer) |
| Signal
A domain representation of a Reactive
Stream signal. |
| Class and Description |
|---|
| Action
An Action is a reactive component to subscribe to a
Publisher and in particular
to a Stream. |
| CompositeAction
Create a Processor where a given head/tail couple is provided as a Stream (Input upstream) and Action (Output
downstream).
|
| Control
An interface generally associated with a
Stream terminal action such as
Stream.consume(reactor.fn.Consumer) |
| Signal
A domain representation of a Reactive
Stream signal. |
| Signal.Type |
| Class and Description |
|---|
| Action
An Action is a reactive component to subscribe to a
Publisher and in particular
to a Stream. |
| Control
An interface generally associated with a
Stream terminal action such as
Stream.consume(reactor.fn.Consumer) |
| Class and Description |
|---|
| Action
An Action is a reactive component to subscribe to a
Publisher and in particular
to a Stream. |
| Control
An interface generally associated with a
Stream terminal action such as
Stream.consume(reactor.fn.Consumer) |
| Class and Description |
|---|
| Action
An Action is a reactive component to subscribe to a
Publisher and in particular
to a Stream. |
| Control
An interface generally associated with a
Stream terminal action such as
Stream.consume(reactor.fn.Consumer) |
| Class and Description |
|---|
| Action
An Action is a reactive component to subscribe to a
Publisher and in particular
to a Stream. |
| Control
An interface generally associated with a
Stream terminal action such as
Stream.consume(reactor.fn.Consumer) |
| Class and Description |
|---|
| Action
An Action is a reactive component to subscribe to a
Publisher and in particular
to a Stream. |
| Control
An interface generally associated with a
Stream terminal action such as
Stream.consume(reactor.fn.Consumer) |
| Class and Description |
|---|
| Action
An Action is a reactive component to subscribe to a
Publisher and in particular
to a Stream. |
| Control
An interface generally associated with a
Stream terminal action such as
Stream.consume(reactor.fn.Consumer) |
| Class and Description |
|---|
| Action
An Action is a reactive component to subscribe to a
Publisher and in particular
to a Stream. |
| Control
An interface generally associated with a
Stream terminal action such as
Stream.consume(reactor.fn.Consumer) |
| Class and Description |
|---|
| Action
An Action is a reactive component to subscribe to a
Publisher and in particular
to a Stream. |
| Control
An interface generally associated with a
Stream terminal action such as
Stream.consume(reactor.fn.Consumer) |
| Class and Description |
|---|
| Action
An Action is a reactive component to subscribe to a
Publisher and in particular
to a Stream. |
| Control
An interface generally associated with a
Stream terminal action such as
Stream.consume(reactor.fn.Consumer) |
| Signal
A domain representation of a Reactive
Stream signal. |
| Class and Description |
|---|
| Control
An interface generally associated with a
Stream terminal action such as
Stream.consume(reactor.fn.Consumer) |
| Class and Description |
|---|
| Action
An Action is a reactive component to subscribe to a
Publisher and in particular
to a Stream. |
| Control
An interface generally associated with a
Stream terminal action such as
Stream.consume(reactor.fn.Consumer) |
| Class and Description |
|---|
| Action
An Action is a reactive component to subscribe to a
Publisher and in particular
to a Stream. |
| Control
An interface generally associated with a
Stream terminal action such as
Stream.consume(reactor.fn.Consumer) |
| Signal
A domain representation of a Reactive
Stream signal. |
| Class and Description |
|---|
| Action
An Action is a reactive component to subscribe to a
Publisher and in particular
to a Stream. |
| Control
An interface generally associated with a
Stream terminal action such as
Stream.consume(reactor.fn.Consumer) |
| Class and Description |
|---|
| Action
An Action is a reactive component to subscribe to a
Publisher and in particular
to a Stream. |
| CompositeAction
Create a Processor where a given head/tail couple is provided as a Stream (Input upstream) and Action (Output
downstream).
|
Copyright © 2016. All rights reserved.