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 |
TupleN
A tuple that holds 9 or more values
|
Modifier and Type | Method and Description |
---|---|
static <T1,T2,T3,T4,T5,T6,T7,T8> |
Tuple.of(T1 t1,
T2 t2,
T3 t3,
T4 t4,
T5 t5,
T6 t6,
T7 t7,
T8 t8)
Create a
Tuple8 with the given objects. |
Modifier and Type | Method and Description |
---|---|
static <T1,T2,T3,T4,T5,T6,T7,T8> |
Promises.when(Promise<T1> p1,
Promise<T2> p2,
Promise<T3> p3,
Promise<T4> p4,
Promise<T5> p5,
Promise<T6> p6,
Promise<T7> p7,
Promise<T8> p8)
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,T4,T5,T6,T7,T8,V> |
Streams.combineLatest(org.reactivestreams.Publisher<? extends T1> source1,
org.reactivestreams.Publisher<? extends T2> source2,
org.reactivestreams.Publisher<? extends T3> source3,
org.reactivestreams.Publisher<? extends T4> source4,
org.reactivestreams.Publisher<? extends T5> source5,
org.reactivestreams.Publisher<? extends T6> source6,
org.reactivestreams.Publisher<? extends T7> source7,
org.reactivestreams.Publisher<? extends T8> source8,
Function<Tuple8<T1,T2,T3,T4,T5,T6,T7,T8>,? 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,T4,T5,T6,T7,T8,V> |
Streams.zip(org.reactivestreams.Publisher<? extends T1> source1,
org.reactivestreams.Publisher<? extends T2> source2,
org.reactivestreams.Publisher<? extends T3> source3,
org.reactivestreams.Publisher<? extends T4> source4,
org.reactivestreams.Publisher<? extends T5> source5,
org.reactivestreams.Publisher<? extends T6> source6,
org.reactivestreams.Publisher<? extends T7> source7,
org.reactivestreams.Publisher<? extends T8> source8,
Function<Tuple8<T1,T2,T3,T4,T5,T6,T7,T8>,? extends V> combinator)
Build a Stream whose data are generated by the passed publishers.
|
Copyright © 2016. All rights reserved.