如何定期使用项目反应器对Flux进行采样？

Question

我当前的尝试在下面，但这只打印一个值。我希望采样定期继续，以便每秒打印一个值。如何做到这一点？

import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import reactor.core.publisher.Flux;

import java.time.Duration;

public class Test {
    private static final Logger logger = LogManager.getLogger(Test.class);

    public static void main(String[] args) {

        Flux.<String>create(sink -> sink.next("HEARTBEAT"))
                .sample(Flux.interval(Duration.ofSeconds(1)))
                .subscribe(logger::info);

        try {
            Thread.sleep(10000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}

Answer 1

您的示例中的采样确实会定期进行，它将每秒采样一次。然而，您的原始通量。createcall只创建一个值，所以只有一个值需要采样！

如果您将Flux.create（）替换为Flux.generate（），它将不断流式传输“HEARTBEAT”，因此您的采样将按预期工作。