程序包 | 说明 |
---|---|
reactor.core.publisher | |
reactor.util.function |
Tuples provide a type-safe way to specify multiple parameters. |
限定符和类型 | 方法和说明 |
---|---|
static <T1,T2,T3,T4,T5,T6> |
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)
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
Tuple6 . |
static <T1,T2,T3,T4,T5,T6> |
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)
Zip six sources together, that is to say wait for all the sources to emit one
element and combine these elements once into a
Tuple6 . |
static <T1,T2,T3,T4,T5,T6> |
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)
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
Tuple6 and delaying errors. |
限定符和类型 | 类和说明 |
---|---|
class |
Tuple7<T1,T2,T3,T4,T5,T6,T7>
A tuple that holds seven non-null values
|
class |
Tuple8<T1,T2,T3,T4,T5,T6,T7,T8>
A tuple that holds eight values
|
限定符和类型 | 方法和说明 |
---|---|
<R> Tuple6<R,T2,T3,T4,T5,T6> |
Tuple6.mapT1(java.util.function.Function<T1,R> mapper)
Map the 1st part (T1) of this
Tuple6 into a different value and type,
keeping the other parts. |
<R> Tuple6<T1,R,T3,T4,T5,T6> |
Tuple6.mapT2(java.util.function.Function<T2,R> mapper)
Map the 2nd part (T2) of this
Tuple6 into a different value and type,
keeping the other parts. |
<R> Tuple6<T1,T2,R,T4,T5,T6> |
Tuple6.mapT3(java.util.function.Function<T3,R> mapper)
Map the 3rd part (T3) of this
Tuple6 into a different value and type,
keeping the other parts. |
<R> Tuple6<T1,T2,T3,R,T5,T6> |
Tuple6.mapT4(java.util.function.Function<T4,R> mapper)
Map the 4th part (T4) of this
Tuple6 into a different value and type,
keeping the other parts. |
<R> Tuple6<T1,T2,T3,T4,R,T6> |
Tuple6.mapT5(java.util.function.Function<T5,R> mapper)
Map the 5th part (T5) of this
Tuple6 into a different value and type,
keeping the other parts. |
<R> Tuple6<T1,T2,T3,T4,T5,R> |
Tuple6.mapT6(java.util.function.Function<T6,R> mapper)
Map the 6th part (T6) of this
Tuple6 into a different value and type,
keeping the other parts. |
static <T1,T2,T3,T4,T5,T6> |
Tuples.of(T1 t1,
T2 t2,
T3 t3,
T4 t4,
T5 t5,
T6 t6)
Create a
Tuple6 with the given objects. |
限定符和类型 | 方法和说明 |
---|---|
static <T1,T2,T3,T4,T5,T6> |
Tuples.fn6()
A converting function from Object array to
Tuple6 |
限定符和类型 | 方法和说明 |
---|---|
static <T1,T2,T3,T4,T5,T6,R> |
Tuples.fn6(java.util.function.Function<Tuple6<T1,T2,T3,T4,T5,T6>,R> delegate)
A converting function from Object array to
Tuple6 to R. |