Package | Description |
---|---|
reactor.fn.tuple |
Tuples provide a type-safe way to specify multiple parameters.
|
reactor.rx |
Streams are reactive components derived from Reactive Extensions and implementing Reactive Streams specification.
|
Modifier and Type | Class and Description |
---|---|
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,T3> Tuple3<T1,T2,T3> |
Tuple.of(T1 t1,
T2 t2,
T3 t3)
Create a
Tuple3 with the given objects. |
Modifier and Type | Method and Description |
---|---|
static <T1,T2,T3> Promise<Tuple3<T1,T2,T3>> |
Promises.when(Promise<T1> p1,
Promise<T2> p2,
Promise<T3> p3)
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,T3,V> |
Streams.combineLatest(org.reactivestreams.Publisher<? extends T1> source1,
org.reactivestreams.Publisher<? extends T2> source2,
org.reactivestreams.Publisher<? extends T3> source3,
Function<Tuple3<T1,T2,T3>,? extends V> combinator)
Build a Stream whose data are generated by the combination of the most recent published values from
all publishers.
|
static <T1,T2,T3,V> |
Streams.zip(org.reactivestreams.Publisher<? extends T1> source1,
org.reactivestreams.Publisher<? extends T2> source2,
org.reactivestreams.Publisher<? extends T3> source3,
Function<Tuple3<T1,T2,T3>,? extends V> combinator)
Build a Stream whose data are generated by the passed publishers.
|
Copyright © 2017. All rights reserved.