程序包 | 说明 |
---|---|
reactor.core.publisher | |
reactor.util.function |
Tuples provide a type-safe way to specify multiple parameters. |
限定符和类型 | 方法和说明 |
---|---|
static <T1,T2,T3,T4,T5,T6,T7,T8> |
Mono.zip(Mono<? extends T1> p1,
Mono<? extends T2> p2,
Mono<? extends T3> p3,
Mono<? extends T4> p4,
Mono<? extends T5> p5,
Mono<? extends T6> p6,
Mono<? extends T7> p7,
Mono<? extends T8> p8)
Merge given monos into a new Mono that will be fulfilled when all of the given Monos
have produced an item, aggregating their values into a
Tuple8 . |
static <T1,T2,T3,T4,T5,T6,T7,T8> |
Flux.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)
Zip eight sources together, that is to say wait for all the sources to emit one
element and combine these elements once into a
Tuple8 . |
static <T1,T2,T3,T4,T5,T6,T7,T8> |
Mono.zipDelayError(Mono<? extends T1> p1,
Mono<? extends T2> p2,
Mono<? extends T3> p3,
Mono<? extends T4> p4,
Mono<? extends T5> p5,
Mono<? extends T6> p6,
Mono<? extends T7> p7,
Mono<? extends T8> p8)
Merge given monos into a new Mono that will be fulfilled when all of the given Monos
have produced an item, aggregating their values into a
Tuple8 and delaying errors. |
限定符和类型 | 方法和说明 |
---|---|
<R> Tuple8<R,T2,T3,T4,T5,T6,T7,T8> |
Tuple8.mapT1(java.util.function.Function<T1,R> mapper)
Map the 1st part (T1) of this
Tuple8 into a different value and type,
keeping the other parts. |
<R> Tuple8<T1,R,T3,T4,T5,T6,T7,T8> |
Tuple8.mapT2(java.util.function.Function<T2,R> mapper)
Map the 2nd part (T2) of this
Tuple8 into a different value and type,
keeping the other parts. |
<R> Tuple8<T1,T2,R,T4,T5,T6,T7,T8> |
Tuple8.mapT3(java.util.function.Function<T3,R> mapper)
Map the 3rd part (T3) of this
Tuple8 into a different value and type,
keeping the other parts. |
<R> Tuple8<T1,T2,T3,R,T5,T6,T7,T8> |
Tuple8.mapT4(java.util.function.Function<T4,R> mapper)
Map the 4th part (T4) of this
Tuple8 into a different value and type,
keeping the other parts. |
<R> Tuple8<T1,T2,T3,T4,R,T6,T7,T8> |
Tuple8.mapT5(java.util.function.Function<T5,R> mapper)
Map the 5th part (T5) of this
Tuple8 into a different value and type,
keeping the other parts. |
<R> Tuple8<T1,T2,T3,T4,T5,R,T7,T8> |
Tuple8.mapT6(java.util.function.Function<T6,R> mapper)
Map the 6th part (T6) of this
Tuple8 into a different value and type,
keeping the other parts. |
<R> Tuple8<T1,T2,T3,T4,T5,T6,R,T8> |
Tuple8.mapT7(java.util.function.Function<T7,R> mapper)
Map the 7th part (T7) of this
Tuple8 into a different value and type,
keeping the other parts. |
<R> Tuple8<T1,T2,T3,T4,T5,T6,T7,R> |
Tuple8.mapT8(java.util.function.Function<T8,R> mapper)
Map the 8th part (t8) of this
Tuple8 into a different value and type,
keeping the other parts. |
static <T1,T2,T3,T4,T5,T6,T7,T8> |
Tuples.of(T1 t1,
T2 t2,
T3 t3,
T4 t4,
T5 t5,
T6 t6,
T7 t7,
T8 t8)
Create a
Tuple8 with the given objects. |
限定符和类型 | 方法和说明 |
---|---|
static <T1,T2,T3,T4,T5,T6,T7,T8> |
Tuples.fn8()
A converting function from Object array to
Tuple8 |
限定符和类型 | 方法和说明 |
---|---|
static <T1,T2,T3,T4,T5,T6,T7,T8,R> |
Tuples.fn8(java.util.function.Function<Tuple8<T1,T2,T3,T4,T5,T6,T7,T8>,R> delegate)
A converting function from Object array to
Tuple8 |