Package | Description |
---|---|
reactor.fn.tuple |
Tuples provide a type-safe way to specify multiple parameters.
|
reactor.groovy.support | |
reactor.rx |
Streams are reactive components derived from Reactive Extensions and implementing Reactive Streams specification.
|
reactor.rx.action.combination |
Modifier and Type | Class and Description |
---|---|
class |
Tuple1<T1>
A tuple that holds a single value
|
class |
Tuple2<T1,T2>
A tuple that holds two values
|
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 Tuple |
Tuple.empty()
Create a
Tuple1 with the given object. |
Modifier and Type | Method and Description |
---|---|
void |
ClosureTupleConsumer.accept(Tuple tup) |
Modifier and Type | Method and Description |
---|---|
static <TUPLE extends Tuple,V> |
Streams.combineLatest(List<? extends org.reactivestreams.Publisher<?>> sources,
Function<TUPLE,? extends V> combinator)
Build a Stream whose data are generated by the combination of the most recent published values from
all publishers.
|
static <E,TUPLE extends Tuple,V> |
Streams.combineLatest(org.reactivestreams.Publisher<? extends org.reactivestreams.Publisher<E>> sources,
Function<TUPLE,? extends V> combinator)
Build a Stream whose data are generated by the combination of the most recent published values from
all publishers.
|
static <TUPLE extends Tuple,V> |
Streams.zip(List<? extends org.reactivestreams.Publisher<?>> sources,
Function<TUPLE,? extends V> combinator)
Build a Stream whose data are generated by the passed publishers.
|
static <E,TUPLE extends Tuple,V> |
Streams.zip(org.reactivestreams.Publisher<? extends org.reactivestreams.Publisher<E>> sources,
Function<TUPLE,? extends V> combinator)
Build a Stream whose data are generated by the passed publishers.
|
Modifier and Type | Class and Description |
---|---|
class |
CombineLatestAction<O,V,TUPLE extends Tuple> |
class |
ZipAction<O,V,TUPLE extends Tuple> |
Modifier and Type | Method and Description |
---|---|
static <TUPLE extends Tuple,V> |
ZipAction.joinZipper() |
Copyright © 2017. All rights reserved.