Package | Description |
---|---|
reactor.bus |
Hold the required abstraction to enable Event Driven Programming with Reactor.
|
reactor.fn |
This package contains the foundational abstractions on which Reactor's functional and reactive components are
built.
|
reactor.fn.tuple |
Tuples provide a type-safe way to specify multiple parameters.
|
reactor.groovy.ext | |
reactor.groovy.support | |
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.impl.netty.http | |
reactor.io.net.impl.netty.tcp | |
reactor.io.net.impl.zmq.tcp | |
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.pair | |
reactor.rx.stream |
Modifier and Type | Method and Description |
---|---|
Iterator<Tuple2<String,Object>> |
Event.Headers.iterator()
Returns an unmodifiable Iterator over a copy of this Headers' contents.
|
Modifier and Type | Method and Description |
---|---|
static <LEFT,RIGHT,V> |
Functions.functionFrom(BiFunction<LEFT,RIGHT,V> pairFunction)
Deprecated.
Wrap a given
BiFunction that applies transformation to a Tuple2 into a Function Tuple2. |
Modifier and Type | Method and Description |
---|---|
static <LEFT,RIGHT,V> |
Functions.pairFrom(Function<Tuple2<LEFT,RIGHT>,V> function)
Deprecated.
Wrap a given
Function that applies transformation to a Tuple2 into a PairFunction. |
Modifier and Type | Class and Description |
---|---|
class |
Tuple3<T1,T2,T3>
A tuple that holds three values
|
class |
Tuple4<T1,T2,T3,T4>
A tuple that holds four values
|
class |
Tuple5<T1,T2,T3,T4,T5>
A tuple that holds five values
|
class |
Tuple6<T1,T2,T3,T4,T5,T6>
A tuple that holds six values
|
class |
Tuple7<T1,T2,T3,T4,T5,T6,T7>
A tuple that holds seven values
|
class |
Tuple8<T1,T2,T3,T4,T5,T6,T7,T8>
A tuple that holds eight values
|
class |
TupleN
A tuple that holds 9 or more values
|
Modifier and Type | Method and Description |
---|---|
static <T1,T2> Tuple2<T1,T2> |
Tuple.of(T1 t1,
T2 t2)
Create a
Tuple2 with the given objects. |
Modifier and Type | Method and Description |
---|---|
static <K,V> Stream<Tuple2<K,V>> |
StreamExtensions.reduceByKey(org.reactivestreams.Publisher<? extends Tuple2<K,V>> selfType,
BiFunction<V,V,V> accumulator) |
static <K,V> Stream<Tuple2<K,V>> |
StreamExtensions.scanByKey(org.reactivestreams.Publisher<? extends Tuple2<K,V>> selfType,
BiFunction<V,V,V> accumulator) |
Modifier and Type | Method and Description |
---|---|
static <K,V> Stream<Tuple2<K,V>> |
StreamExtensions.reduceByKey(org.reactivestreams.Publisher<? extends Tuple2<K,V>> selfType,
BiFunction<V,V,V> accumulator) |
static <K,V> Stream<Tuple2<K,V>> |
StreamExtensions.scanByKey(org.reactivestreams.Publisher<? extends Tuple2<K,V>> selfType,
BiFunction<V,V,V> accumulator) |
Modifier and Type | Method and Description |
---|---|
V |
ClosureReduce.apply(Tuple2<T,V> t) |
Modifier and Type | Method and Description |
---|---|
Tuple2<InetSocketAddress,Long> |
Reconnect.reconnect(InetSocketAddress currentAddress,
int attempt)
Provide an
InetSocketAddress to which a reconnection attempt should be made. |
Modifier and Type | Method and Description |
---|---|
protected abstract Stream<Tuple2<InetSocketAddress,Integer>> |
ReactorClient.doStart(ReactorChannelHandler<IN,OUT,CONN> handler,
Reconnect reconnect) |
Stream<Tuple2<InetSocketAddress,Integer>> |
ReactorClient.start(ReactorChannelHandler<IN,OUT,CONN> handler,
Reconnect reconnect)
Open a channel to the configured address and return a
Stream that will be populated
by the ChannelStream every time a connection or reconnection is made. |
Modifier and Type | Method and Description |
---|---|
protected Stream<Tuple2<InetSocketAddress,Integer>> |
NettyHttpClient.doStart(ReactorChannelHandler<IN,OUT,HttpChannel<IN,OUT>> handler,
Reconnect reconnect) |
Modifier and Type | Method and Description |
---|---|
protected Stream<Tuple2<InetSocketAddress,Integer>> |
NettyTcpClient.doStart(ReactorChannelHandler<IN,OUT,ChannelStream<IN,OUT>> handler,
Reconnect reconnect) |
Modifier and Type | Method and Description |
---|---|
protected Stream<Tuple2<InetSocketAddress,Integer>> |
ZeroMQTcpClient.doStart(ReactorChannelHandler handler,
Reconnect reconnect) |
Modifier and Type | Method and Description |
---|---|
Stream<Tuple2<Long,O>> |
Stream.elapsed()
|
static <KEY,VALUE> |
BiStreams.reduceByKey(org.reactivestreams.Publisher<Tuple2<KEY,VALUE>> publisher,
BiFunction<VALUE,VALUE,VALUE> accumulator) |
static <KEY,VALUE> |
BiStreams.reduceByKey(org.reactivestreams.Publisher<Tuple2<KEY,VALUE>> publisher,
Map<KEY,VALUE> store,
org.reactivestreams.Publisher<? extends MapStream.Signal<KEY,VALUE>> listener,
BiFunction<VALUE,VALUE,VALUE> accumulator) |
static <KEY,VALUE> |
BiStreams.reduceByKey(org.reactivestreams.Publisher<Tuple2<KEY,VALUE>> publisher,
MapStream<KEY,VALUE> mapStream,
BiFunction<VALUE,VALUE,VALUE> accumulator) |
static <KEY,VALUE> |
BiStreams.reduceByKeyOn(org.reactivestreams.Publisher<Tuple2<KEY,VALUE>> publisher,
Map<KEY,VALUE> store,
org.reactivestreams.Publisher<? extends MapStream.Signal<KEY,VALUE>> listener,
BiFunction<VALUE,VALUE,VALUE> accumulator) |
static <KEY,VALUE> |
BiStreams.scanByKey(org.reactivestreams.Publisher<Tuple2<KEY,VALUE>> publisher,
BiFunction<VALUE,VALUE,VALUE> accumulator) |
static <KEY,VALUE> |
BiStreams.scanByKey(org.reactivestreams.Publisher<Tuple2<KEY,VALUE>> publisher,
Map<KEY,VALUE> store,
org.reactivestreams.Publisher<? extends MapStream.Signal<KEY,VALUE>> listener,
BiFunction<VALUE,VALUE,VALUE> accumulator) |
static <KEY,VALUE> |
BiStreams.scanByKey(org.reactivestreams.Publisher<Tuple2<KEY,VALUE>> publisher,
MapStream<KEY,VALUE> mapStream,
BiFunction<VALUE,VALUE,VALUE> accumulator) |
static <KEY,VALUE> |
BiStreams.scanByKeyOn(org.reactivestreams.Publisher<Tuple2<KEY,VALUE>> publisher,
Map<KEY,VALUE> store,
org.reactivestreams.Publisher<? extends MapStream.Signal<KEY,VALUE>> listener,
BiFunction<VALUE,VALUE,VALUE> accumulator) |
Stream<Tuple2<Long,O>> |
Stream.timestamp()
|
static <T1,T2> Promise<Tuple2<T1,T2>> |
Promises.when(Promise<T1> p1,
Promise<T2> p2)
Merge given promises into a new a Promise that will be fulfilled when all of the given Promise
Promises have been fulfilled.
|
Modifier and Type | Method and Description |
---|---|
static <T1,T2,V> Stream<V> |
Streams.combineLatest(org.reactivestreams.Publisher<? extends T1> source1,
org.reactivestreams.Publisher<? extends T2> source2,
Function<Tuple2<T1,T2>,? extends V> combinator)
Build a Stream whose data are generated by the combination of the most recent published values from
all publishers.
|
static <KEY,VALUE> |
BiStreams.reduceByKey(org.reactivestreams.Publisher<Tuple2<KEY,VALUE>> publisher,
BiFunction<VALUE,VALUE,VALUE> accumulator) |
static <KEY,VALUE> |
BiStreams.reduceByKey(org.reactivestreams.Publisher<Tuple2<KEY,VALUE>> publisher,
Map<KEY,VALUE> store,
org.reactivestreams.Publisher<? extends MapStream.Signal<KEY,VALUE>> listener,
BiFunction<VALUE,VALUE,VALUE> accumulator) |
static <KEY,VALUE> |
BiStreams.reduceByKey(org.reactivestreams.Publisher<Tuple2<KEY,VALUE>> publisher,
MapStream<KEY,VALUE> mapStream,
BiFunction<VALUE,VALUE,VALUE> accumulator) |
static <KEY,VALUE> |
BiStreams.reduceByKeyOn(org.reactivestreams.Publisher<Tuple2<KEY,VALUE>> publisher,
Map<KEY,VALUE> store,
org.reactivestreams.Publisher<? extends MapStream.Signal<KEY,VALUE>> listener,
BiFunction<VALUE,VALUE,VALUE> accumulator) |
static <KEY,VALUE> |
BiStreams.scanByKey(org.reactivestreams.Publisher<Tuple2<KEY,VALUE>> publisher,
BiFunction<VALUE,VALUE,VALUE> accumulator) |
static <KEY,VALUE> |
BiStreams.scanByKey(org.reactivestreams.Publisher<Tuple2<KEY,VALUE>> publisher,
Map<KEY,VALUE> store,
org.reactivestreams.Publisher<? extends MapStream.Signal<KEY,VALUE>> listener,
BiFunction<VALUE,VALUE,VALUE> accumulator) |
static <KEY,VALUE> |
BiStreams.scanByKey(org.reactivestreams.Publisher<Tuple2<KEY,VALUE>> publisher,
MapStream<KEY,VALUE> mapStream,
BiFunction<VALUE,VALUE,VALUE> accumulator) |
static <KEY,VALUE> |
BiStreams.scanByKeyOn(org.reactivestreams.Publisher<Tuple2<KEY,VALUE>> publisher,
Map<KEY,VALUE> store,
org.reactivestreams.Publisher<? extends MapStream.Signal<KEY,VALUE>> listener,
BiFunction<VALUE,VALUE,VALUE> accumulator) |
static <T1,T2,V> Stream<V> |
Streams.zip(org.reactivestreams.Publisher<? extends T1> source1,
org.reactivestreams.Publisher<? extends T2> source2,
Function<Tuple2<T1,T2>,? extends V> combinator)
Build a Stream whose data are generated by the passed publishers.
|
<T2,V> Stream<V> |
Stream.zipWith(Iterable<? extends T2> iterable,
Function<Tuple2<O,T2>,V> zipper)
|
<T2,V> Stream<V> |
Stream.zipWith(org.reactivestreams.Publisher<? extends T2> publisher,
Function<Tuple2<O,T2>,V> zipper)
|
Modifier and Type | Method and Description |
---|---|
<E> Action<I,O> |
Action.control(Stream<E> controlStream,
Consumer<Tuple2<Action<I,O>,? super E>> controller)
Consume a Stream to allow for dynamic
Action update. |
Modifier and Type | Method and Description |
---|---|
protected void |
ReduceByKeyAction.doNext(PushSubscription<Tuple2<K,V>> subscriber,
Tuple2<K,V> ev) |
protected void |
ScanByKeyAction.doNext(PushSubscription<Tuple2<K,V>> subscriber,
Tuple2<K,V> ev) |
protected void |
ScanByKeyAction.doNext(Tuple2<K,V> ev) |
Modifier and Type | Method and Description |
---|---|
protected void |
ReduceByKeyAction.doNext(PushSubscription<Tuple2<K,V>> subscriber,
Tuple2<K,V> ev) |
protected void |
ScanByKeyAction.doNext(PushSubscription<Tuple2<K,V>> subscriber,
Tuple2<K,V> ev) |
void |
ScanByKeyAction.subscribe(org.reactivestreams.Subscriber<? super Tuple2<K,V>> subscriber) |
Modifier and Type | Method and Description |
---|---|
Tuple2<K,V> |
MapStream.Signal.pair() |
Modifier and Type | Method and Description |
---|---|
Stream<Tuple2<K,V>> |
MapStream.onPut()
Return a Stream of key/value tuples for only new or updated entries.
|
Copyright © 2017. All rights reserved.