Package | Description |
---|---|
reactor.groovy.ext | |
reactor.io.net |
Reactive network components are located in this package scope implementing the following exposed contract:
A
ReactorPeer NetServer/NetClient is a Publisher of
ReactorChannel that are themselves Publisher of input data. |
reactor.io.net.http |
Components for writing HTTP-based clients and servers using Reactor abstractions.
|
reactor.io.net.impl.netty |
Implementations of the various TCP abstractions based on Netty.
|
reactor.io.net.impl.netty.http | |
reactor.io.net.impl.netty.tcp | |
reactor.io.net.impl.netty.udp | |
reactor.io.net.impl.zmq | |
reactor.io.net.impl.zmq.tcp | |
reactor.io.net.udp | |
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 | |
reactor.rx.stream.io |
Stream implementations that provide for IO access, for instance read/read-write persisting streams |
reactor.rx.subscription | |
reactor.rx.subscription.support |
Class and Description |
---|
Promise
A
Promise is a stateful event container that accepts a single value or error. |
Stream
Base class for components designed to provide a succinct API for working with future values.
|
Class and Description |
---|
Promise
A
Promise is a stateful event container that accepts a single value or error. |
Stream
Base class for components designed to provide a succinct API for working with future values.
|
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 and Description |
---|
Promise
A
Promise is a stateful event container that accepts a single value or error. |
Stream
Base class for components designed to provide a succinct API for working with future values.
|
Class and Description |
---|
Stream
Base class for components designed to provide a succinct API for working with future values.
|
Class and Description |
---|
Promise
A
Promise is a stateful event container that accepts a single value or error. |
Stream
Base class for components designed to provide a succinct API for working with future values.
|
Class and Description |
---|
Promise
A
Promise is a stateful event container that accepts a single value or error. |
Stream
Base class for components designed to provide a succinct API for working with future values.
|
Class and Description |
---|
Promise
A
Promise is a stateful event container that accepts a single value or error. |
Class and Description |
---|
Stream
Base class for components designed to provide a succinct API for working with future values.
|
Class and Description |
---|
Promise
A
Promise is a stateful event container that accepts a single value or error. |
Stream
Base class for components designed to provide a succinct API for working with future values.
|
Class and Description |
---|
Promise
A
Promise is a stateful event container that accepts a single value or error. |
Class and Description |
---|
Promise
A
Promise is a stateful event container that accepts a single value or error. |
Promise.FinalState |
Stream
Base class for components designed to provide a succinct API for working with future values.
|
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...). |
StreamUtils.StreamVisitor |
Class and Description |
---|
Stream
Base class for components designed to provide a succinct API for working with future values.
|
StreamUtils.StreamVisitor |
Class and Description |
---|
Stream
Base class for components designed to provide a succinct API for working with future values.
|
Class and Description |
---|
Stream
Base class for components designed to provide a succinct API for working with future values.
|
Class and Description |
---|
Stream
Base class for components designed to provide a succinct API for working with future values.
|
Class and Description |
---|
Stream
Base class for components designed to provide a succinct API for working with future values.
|
Class and Description |
---|
Stream
Base class for components designed to provide a succinct API for working with future values.
|
Class and Description |
---|
Stream
Base class for components designed to provide a succinct API for working with future values.
|
Class and Description |
---|
Stream
Base class for components designed to provide a succinct API for working with future values.
|
Class and Description |
---|
Stream
Base class for components designed to provide a succinct API for working with future values.
|
Class and Description |
---|
Stream
Base class for components designed to provide a succinct API for working with future values.
|
Class and Description |
---|
StreamUtils.StreamVisitor |
Class and Description |
---|
Stream
Base class for components designed to provide a succinct API for working with future values.
|
Class and Description |
---|
Stream
Base class for components designed to provide a succinct API for working with future values.
|
Class and Description |
---|
Stream
Base class for components designed to provide a succinct API for working with future values.
|
Class and Description |
---|
Stream
Base class for components designed to provide a succinct API for working with future values.
|
Class and Description |
---|
Stream
Base class for components designed to provide a succinct API for working with future values.
|
Class and Description |
---|
Stream
Base class for components designed to provide a succinct API for working with future values.
|
Class and Description |
---|
Stream
Base class for components designed to provide a succinct API for working with future values.
|
Copyright © 2017. All rights reserved.