Reactor 3 （3）: 创建Publisher之Flux

本文主要是介绍Reactor 3 （3）: 创建Publisher之Flux，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

创建Flux

上一篇介绍了Mono，mono表示0~1的序列，flux用来表示0~N个元素序列，mono是flux的简化版，flux可以用来表示流

因为是表示连续序列Flux和Mono的创建方法，有些不同，下面是flux的一些创建方法：

• just()：可以指定序列中包含的全部元素。
• range(): 可以用来创建连续数值
• empty()：创建一个不包含任何元素。
• error(Throwable error)：创建一个只包含错误消息的序列。
• fromIterable(): 通过迭代器创建如list，set
• fromStream(): 通过流创建
• fromArray(T[]): 通过列表创建 如 String[], Integer[]
• merge(): 通过将两个flux合并得到新的flux
• interval(): 每隔一段时间生成一个数字，从1开始递增

如下为创建flux示例：

    @Testpublic void flux () throws InterruptedException {Flux<Integer> intFlux = Flux.just(1, 2, 3, 4, 5);Flux<Integer> rangeFlux = Flux.range(6, 4);  // 以6开始，取4个值：6,7,8,9Flux.fromArray(new Integer[]{1

这篇关于Reactor 3 （3）: 创建Publisher之Flux的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！

---