我的usecase是创建如下所示的反应性端点: ServicePoller poller =So that I can access collection later on without polling again */
这会在数据可用时立即将数据发回前端,然而,我的第二个用例是在数据到达时将数据集中到一个单独的集合中在从原始流量返回控制器之前,我尝试订阅
我有一个用于流的Flux生成器(来自项目反应堆),它延迟1秒来释放每个元素。由于流是无限的,所以我也决定使用take()方法要使用多少个元素。我想测试这样的方法是否可以在给定的时间内执行。我试图创建我的解决方案,但没有成功。这是Flux方法import java.time.Duration;public class FluxAndMonoStreamsimport org.juni