如何理解Java8 Stream API是拉,Reactor是推

西夏一品堂 发布于 2017/10/13 13:21
阅读 420
收藏 0

在Java8 Stream API里面,如果只有中间操作,没有终止操作。数据是不会进行处理的。
比如说,下面代码不会输出的

Stream.of("aa", "bb").map(x -> {
	System.out.println("Stream input : " + x);
	return x;
});

但是,在Reactor中,为什么如下代码也没有执行

Flux.just("aa", "bb").map(x -> {
	System.out.println("Reactor input : " + x);
	return x;
});

Java8 Stream是只有碰到终止操作,才会真正执行。可以理解为拉

但是,为啥上面reactor的代码也没有执行,reactor不是推的吗?也就是说,就算没有终止操作,也会执行的吧?

请问,我的理解有没有问题?

加载中
0
開源中國張學友
開源中國張學友

我觉得不能理解为拉推,推也得有推操作吧(推其实也是一种终止操作),不然你一个代码无缘无故就推了,岂不是很让人费解。

返回顶部
顶部