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 |
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,T4,T5,T6,T7> |
Tuple.of(T1 t1,
T2 t2,
T3 t3,
T4 t4,
T5 t5,
T6 t6,
T7 t7)
Create a
Tuple7 with the given objects. |
Modifier and Type | Method and Description |
---|---|
static <T1,T2,T3,T4,T5,T6,T7> |
Promises.when(Promise<T1> p1,
Promise<T2> p2,
Promise<T3> p3,
Promise<T4> p4,
Promise<T5> p5,
Promise<T6> p6,
Promise<T7> p7)
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,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,
Function<Tuple7<T1,T2,T3,T4,T5,T6,T7>,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,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,
Function<Tuple7<T1,T2,T3,T4,T5,T6,T7>,V> combinator)
Build a Stream whose data are generated by the passed publishers.
|
Copyright © 2016. All rights reserved.