如何使用电抗器3.x将LIST<;T&>;转换为通量<;T&>

本文介绍了如何使用电抗器3.x将LIST&lt;T&>;转换为通量&lt;T&>的处理方法,对大家解决问题具有一定的参考价值,需要的朋友们下面随着小编来一起学习吧!,我有一个Asyn Call Thrift接口:,现在它返回CompletableFuture&lt;列表&gt;。然后我调用它来使用Flux做一些处理器。,但是,我想从getFavourites方法中获取一个通量,并且可以在getRecommend方法中使用它。
或者,您可以推荐Flux API,我可以将List<Long> recommendList转换为Flux<Long> recommendFlux。,要将CompletableFuture<List<T>>转换为Flux<T>,可以使用Mono#fromFutureMono#flatMapMany:,List<T>在回调中异步接收到的Flux<T>也可以不使用CompletableFuture转换为Flux<T>
您可以直接使用Mono#createMono#flatMapMany:,或简单使用Flux#create一次多次排放:,这篇关于如何使用电抗器3.x将LIST&lt;T&>;转换为通量&lt;T&>的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,
返回顶部
跳到底部

Copyright 2011-2024 南京追名网络科技有限公司 苏ICP备2023031119号-6 乌徒帮 All Rights Reserved Powered by Z-BlogPHP Theme By open开发

请先 登录 再评论,若不是会员请先 注册