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 © 2017. All rights reserved.