小编Fel*_*lix的帖子

Infinite Java Stream和Reactor Flux之间的区别

我正在尝试找出无限流和无限磁通量(如果有)之间的概念差异。

为此,我想出了以下示例来说明无限的流/通量

@Test
public void infinteStream() {

  //Prints infinite number of integers
  Stream<Integer> infiniteStream = Stream.iterate(0, i -> i+1);

  infiniteStream.forEach(System.out::println);
}

@Test
public void infiniteFlux()  {

   //Prints infinite number of date strings (every second)
   Flux<LocalDateTime> localDateTimeFlux = Flux.interval(Duration.ofSeconds(1))
            .map(t -> LocalDateTime.now());

    localDateTimeFlux.subscribe(t -> System.out.println(t.format(DateTimeFormatter.ofPattern("yyyy-MM-dd hh:mm:ss"))));
}
Run Code Online (Sandbox Code Playgroud)

关于这些示例,我有一个问题:是否有带Flux的infinteStream()和带Stream的infinteFlux()的模拟?而且,更一般而言,无限流和磁通量之间有什么区别吗?

在此先感谢Felix

java reactor flux java-stream spring-webflux

4
推荐指数
1
解决办法
1463
查看次数

标签 统计

flux ×1

java ×1

java-stream ×1

reactor ×1

spring-webflux ×1