如何理解Reactor中的Flux.sampleTimeout方法?

问题描述 投票:0回答:0

此方法的 2 个重载:

public final <U> Flux<T> sampleTimeout(Function<? super T,? extends Publisher<U>> throttlerFactory)

public final <U> Flux<T> sampleTimeout(Function<? super T,? extends Publisher<U>> throttlerFactory,
                                       int maxConcurrency)

https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html

任何人都可以帮助我理解这两种方法? sample和Duration我都看懂了,但是上图中的各种符号我不是很懂

java spring-webflux reactive-programming project-reactor reactive
© www.soinside.com 2019 - 2024. All rights reserved.