Flux.sample(with Duration) 和 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 with Duration我已经了解了,但是我不太了解sampleTimeout()。

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