java - 从项目 react 器中的通量中采样除第一个元素之外的所有元素

Question

在项目 react 堆通量中有一个示例方法Flux#sample java doc 。它会更改通量，以便仅在指定周期结束时发出事件。

是否可以调整此行为并实现此目的:在第一个元素上 - 立即发出它，从第二个到最后开始延迟采样。基本上，我想从采样中排除第一个(且仅第一个)元素，以便无需初始等待即可发出它。

是否可以使用内置运算符来实现？如果没有那么有人知道如何解决这个问题吗？

这是我想要实现的一个最简单的示例:

Flux<String> inputFlux = Flux.just("first", "second", "third").delayElements(Duration.ofMillis(400));
Flux<String> transformed = /*do some magic with input flux*/;

StepVerifier.create(transformed)
    .expectNext("first")//first should always be emmited instantly
    //second arrives 400ms after first
    //third arrives 400ms after second
    .expectNoEvent(Duration.ofSeconds(1))
    .expectNext("third")//after sample period last received element should be received 
    .verifyComplete();

Answer 1

通过将源通量myFlux转换为热通量，您可以轻松实现这一点:

Flux<T> myFlux;
Flux<T> sharedFlux = myFlux.publish().refCount(2);

Flux<T> first = sharedFlux.take(1);
Flux<T> sampledRest = sharedFlux.skip(1).sample(Duration.ofMillis(whatever));

return Flux.merge(first, sampledRest);