类的使用
reactor.util.function.Tuple2

使用Tuple2的程序包

程序包	说明
reactor.core	Core components of the framework supporting extensions to the Reactive Stream programming model.
reactor.core.publisher	Provide main Reactive APIs in Flux and Mono, as well as various helper classes, interfaces used in the composition API, variants of Flux and operator-building utilities.
reactor.guide
reactor.test	Main test components supporting the testing and assertion of publishers.
reactor.util.function	Tuples provide a type-safe way to specify multiple parameters.

reactor.core中Tuple2的使用

类型参数类型为Tuple2的reactor.core中的字段

限定符和类型	字段和说明
static Scannable.Attr<java.util.stream.Stream<Tuple2<java.lang.String,java.lang.String>>>	Scannable.Attr.TAGS A Stream of Tuple2 representing key/value pairs for tagged components.

返回变量类型为Tuple2的类型的reactor.core中的方法

限定符和类型	方法和说明
default java.util.stream.Stream<Tuple2<java.lang.String,java.lang.String>>	Scannable.tags() Visit this Scannable and its Scannable.parents(), starting by the furthest reachable parent, and return a Stream of the tags which includes duplicates and outputs tags in declaration order (grandparent tag(s) > parent tag(s) > current tag(s)).

reactor.core.publisher中Tuple2的使用

类型参数类型为Tuple2的reactor.core.publisher中的方法

限定符和类型	方法和说明
static <TUPLE extends Tuple2,V> Flux<V>	Flux.zip(org.reactivestreams.Publisher<? extends org.reactivestreams.Publisher<?>> sources, java.util.function.Function<? super TUPLE,? extends V> combinator) Zip multiple sources together, that is to say wait for all the sources to emit one element and combine these elements once into an output value (constructed by the provided combinator).

返回变量类型为Tuple2的类型的reactor.core.publisher中的方法

限定符和类型	方法和说明
Mono<Tuple2<java.lang.Long,T>>	Mono.elapsed() 返回一个 Tuple2, 第一个值是生成数据的耗时 Map this Mono into Tuple2<Long, T> of timemillis and source data.
Flux<Tuple2<java.lang.Long,T>>	Flux.elapsed() Map this Flux into Tuple2<Long, T> of timemillis and source data.
Mono<Tuple2<java.lang.Long,T>>	Mono.elapsed(Scheduler scheduler) 返回一个 Tuple2, 第一个值是生成数据的耗时，并指定线程池去记录耗时 Map this Mono sequence into Tuple2<Long, T> of timemillis and source data.
Flux<Tuple2<java.lang.Long,T>>	Flux.elapsed(Scheduler scheduler) Map this Flux into Tuple2<Long, T> of timemillis and source data.
Flux<Tuple2<java.lang.Long,T>>	Flux.index() Keep information about the order in which source values were received by indexing them with a 0-based incrementing long, returning a Flux of Tuple2<(index, value)>.
Mono<Tuple2<java.lang.Long,T>>	Mono.timestamp() 如果此Mono被赋值，则发出一个Tuple对，T1 是当前时钟时间（以毫秒为单位）， T2 为发布的元素 If this Mono is valued, emit a Tuple2 pair of T1 the current clock time in millis (as a Long measured by the parallel Scheduler) and T2 the emitted data (as a T).
Flux<Tuple2<java.lang.Long,T>>	Flux.timestamp() Emit a Tuple2 pair of T1 the current clock time in millis (as a Long measured by the parallel Scheduler) and T2 the emitted data (as a T), for each item from this Flux.
Mono<Tuple2<java.lang.Long,T>>	Mono.timestamp(Scheduler scheduler) If this Mono is valued, emit a Tuple2 pair of T1 the current clock time in millis (as a Long measured by the provided Scheduler) and T2 the emitted data (as a T).
Flux<Tuple2<java.lang.Long,T>>	Flux.timestamp(Scheduler scheduler) Emit a Tuple2 pair of T1 the current clock time in millis (as a Long measured by the provided Scheduler) and T2 the emitted data (as a T), for each item from this Flux.
static <T1,T2> Mono<Tuple2<T1,T2>>	Mono.zip(Mono<? extends T1> p1, Mono<? extends T2> p2) 多个源压缩到一起，等待所有源发出一个元素之后，完成这些源并对返回元素使用元组进行组合。
static <T1,T2> Flux<Tuple2<T1,T2>>	Flux.zip(org.reactivestreams.Publisher<? extends T1> source1, org.reactivestreams.Publisher<? extends T2> source2) Zip two sources together, that is to say wait for all the sources to emit one element and combine these elements once into a Tuple2.
static <T1,T2> Mono<Tuple2<T1,T2>>	Mono.zipDelayError(Mono<? extends T1> p1, Mono<? extends T2> p2) 将给定的 monos 合并到一个新的 Mono 中，当所有给定的 Monos 都产生了一个元素时，它将完成，将它们的值聚合到一个Tuple2并延迟错误。
<T2> Mono<Tuple2<T,T2>>	Mono.zipWhen(java.util.function.Function<T,Mono<? extends T2>> rightGenerator) Wait for the result from this mono, use it to create a second mono via the provided rightGenerator function and combine both results into a Tuple2.
<T2> Mono<Tuple2<T,T2>>	Mono.zipWith(Mono<? extends T2> other) Combine the result from this mono and another into a Tuple2.
<T2> Flux<Tuple2<T,T2>>	Flux.zipWith(org.reactivestreams.Publisher<? extends T2> source2) Zip this Flux with another Publisher source, that is to say wait for both to emit one element and combine these elements once into a Tuple2.
<T2> Flux<Tuple2<T,T2>>	Flux.zipWith(org.reactivestreams.Publisher<? extends T2> source2, int prefetch) Zip this Flux with another Publisher source, that is to say wait for both to emit one element and combine these elements once into a Tuple2.
<T2> Flux<Tuple2<T,T2>>	Flux.zipWithIterable(java.lang.Iterable<? extends T2> iterable) Zip elements from this Flux with the content of an Iterable, that is to say combine one element from each, pairwise, into a Tuple2.

reactor.guide中Tuple2的使用

类型参数类型为Tuple2的reactor.guide中的字段

限定符和类型	字段和说明
static java.util.function.Function<? super Flux<java.lang.String>,Flux<Tuple2<java.lang.Long,java.lang.String>>>	FakeUtils2.enrichUser

reactor.test中Tuple2的使用

类型变量类型为Tuple2的reactor.test中的方法参数

限定符和类型	方法和说明
StepVerifier.Assertions	StepVerifier.Assertions.hasOperatorErrorsMatching(java.util.function.Predicate<java.util.Collection<Tuple2<java.util.Optional<java.lang.Throwable>,java.util.Optional<?>>>> errorsConsumer) Assert that the tested publisher has triggered the onOperatorError hook once or more, and check that the collection of errors and their optionally associated data matches a predicate.
StepVerifier.Assertions	StepVerifier.Assertions.hasOperatorErrorsSatisfying(java.util.function.Consumer<java.util.Collection<Tuple2<java.util.Optional<java.lang.Throwable>,java.util.Optional<?>>>> errorsConsumer) Assert that the tested publisher has triggered the onOperatorError hook once or more, and assert the errors and optionally associated data as a collection.

reactor.util.function中Tuple2的使用

reactor.util.function中Tuple2的子类

限定符和类型	类和说明
class	Tuple3<T1,T2,T3> A tuple that holds three non-null values.
class	Tuple4<T1,T2,T3,T4> A tuple that holds four non-null values
class	Tuple5<T1,T2,T3,T4,T5> A tuple that holds five non-null 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 non-null values
class	Tuple8<T1,T2,T3,T4,T5,T6,T7,T8> A tuple that holds eight values

返回Tuple2的reactor.util.function中的方法

限定符和类型	方法和说明
Tuple2	Tuples.apply(java.lang.Object o)
static Tuple2	Tuples.fromArray(java.lang.Object[] list) Create a Tuple2 with the given array if it is small enough to fit inside a Tuple2 to Tuple8.
<R> Tuple2<R,T2>	Tuple2.mapT1(java.util.function.Function<T1,R> mapper) Map the left-hand part (T1) of this Tuple2 into a different value and type, keeping the right-hand part (T2).
<R> Tuple2<T1,R>	Tuple2.mapT2(java.util.function.Function<T2,R> mapper) Map the right-hand part (T2) of this Tuple2 into a different value and type, keeping the left-hand part (T1).
static <T1,T2> Tuple2<T1,T2>	Tuples.of(T1 t1, T2 t2) Create a Tuple2 with the given objects.

返回变量类型为Tuple2的类型的reactor.util.function中的方法

限定符和类型	方法和说明
static <T1,T2> java.util.function.Function<java.lang.Object[],Tuple2<T1,T2>>	Tuples.fn2() A converting function from Object array to Tuple2
static java.util.function.Function<java.lang.Object[],Tuple2>	Tuples.fnAny() A converting function from Object array to Tuples

类型变量类型为Tuple2的reactor.util.function中的方法参数

限定符和类型	方法和说明
static <R> java.util.function.Function<java.lang.Object[],R>	Tuples.fnAny(java.util.function.Function<Tuple2,R> delegate) A converting function from Object array to Tuples to R.