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

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.
主站蜘蛛池模板: 虹口区| 涿州市| 宁陕县| 铜川市| 宜兰县| 北流市| 化州市| 慈溪市| 突泉县| 云龙县| 鄢陵县| 牙克石市| 库车县| 石门县| 阜宁县| 金平| 岳阳县| 大兴区| 黎川县| 关岭| 万山特区| 博野县| 永福县| 特克斯县| 利津县| 乡城县| 香港 | 广德县| 博客| 克山县| 美姑县| 毕节市| 延川县| 阿拉善盟| 嵊泗县| 景德镇市| 姜堰市| 上栗县| 松江区| 泽州县| 清涧县|