官术网_书友最值得收藏!

Utility methods

Flux offers methods to generate infinite streams and empty streams, or to convert an existing Reactive Stream publisher to Flux. These methods are required to generate streams that can be combined with other streams, using the available operators, as follows:

  • Flux.empty: This method generates an empty stream with no values and only completion.
  • Flux.error: This method generates an error stream with no values and only specified errors.
  • Flux.never: This method generates a stream with no events at all. It does not generate events of any type.
  • Flux.from: This method takes an existing reactive publisher and generates a Flux from it.
  • Flux.defer: This method is used to build a lazy reactive publisher. The method takes a Java 8 supplier to instantiate a subscription-specific Reactive Stream publisher. The publisher instance is only generated when a subscriber makes a subscription to the Flux.
主站蜘蛛池模板: 理塘县| 巧家县| 甘泉县| 茌平县| 忻州市| 南阳市| 大荔县| 绵阳市| 葫芦岛市| 山阴县| 台前县| 左云县| 凤台县| 曲阳县| 镇安县| 武义县| 上高县| 宜兴市| 南涧| 桑植县| 壤塘县| 尉氏县| 铜梁县| 安吉县| 东安县| 肃北| 开化县| 亚东县| 鄯善县| 平原县| 封开县| 上思县| 离岛区| 屏东县| 新巴尔虎右旗| 宝清县| 杂多县| 织金县| 印江| 鞍山市| 兰考县|