1回答
将多个Flux收集为一个
、、、
我想在我的Spring Boot服务中将多个Flux结果收集到一个中。我的方法是： private Flux<VMachineResourceResponse> getDataForPhysicalMachineProtection(
Flux<VMachineResourceResponse> result = Fl
浏览 54提问于2020-08-19得票数 0
回答已采纳
我想要将Flux拆分成多个Lists (或子Fluxes)，每一个元素最多包含20个元素。"a","s","x"...转换为：List<String>, List<String>或Flux<String>, Flux<String> -每个元素最多有20个元素。
浏览 2提问于2021-11-21得票数 1
回答已采纳
通量同步git状态与集群状态，但如果我想删除一个资源从Kubernetes在一个场景中，所有的资源是通过git管理的，什么是最好的方式删除一个资源(支出，服务，入口等)与流量？
浏览 0提问于2019-05-20得票数 3
回答已采纳
我有一个模块，接受实体ID和“解析类型”作为参数，然后通过返回通量的多个操作异步收集数据(主要)。该解析被分解为多个(主要是，再次)异步操作，每个异步操作用于收集有助于解析的不同数据类型。一些解析类型将使所有Flux操作返回数据，而其他类型将收集较少的信息，而一些Flux操作将保持为空。考虑到这一点，我怎么能：
Flux.empty())Add 为</em
浏览 4提问于2020-12-30得票数 0
回答已采纳
2回答
对于每一个字符串，我必须进行一个远程调用。但问题是，进行远程调用的方法实际上返回响应的Mono (显然，由于与单个请求对应，就会有一个响应)。fluxObj.flatmap(a -> makeRemoteCall(a)//converts the Mono of the response to a Flux).reduce(..我无法在返回<e
浏览 1提问于2018-12-31得票数 4
回答已采纳
1回答
我目前正在开发一个应用程序，使用spring starter:2.0.0.M5。我有一个食品卡车mongodb模型，其中包含菜单：@lombok.Getter@lombok.NoArgsConstructor<Menu> getAllMenus() { Flux&l
浏览 3提问于2017-11-06得票数 0
回答已采纳
如何将Monos的贴图转换为Mono，并发出包含每个值的map？
浏览 77提问于2021-08-16得票数 2
回答已采纳
关于我之前的问题Splitting a WebClient Post of a Streaming Flux into JSON Arrays，我使用的是； myFlux .现在，如果没有数据并且超过了Duration，代码将传播一个空的window，这会导致一个空数组被发送。 如何检测到空的window而不运行post
浏览 7提问于2019-06-04得票数 0
回答已采纳
我有一个场景，在这个场景中，我将使用以下命令从DB获取实体列表它将返回Flux<Entity> Flux.fromIterable
浏览 0提问于2019-11-01得票数 1
我试图发送多个分页请求并返回一个Flux<Item>，请求可以并行完成，但结果必须按顺序收集。// the current page number}public FluxpageOfItem.totalPage) {
return chainPageOfItems(page + 1, allItems);
浏览 3提问于2022-06-17得票数 1
回答已采纳
1回答
一个是足球俱乐部，另一个是国家。我想把数据返回给like： public record InitData(Flux<FootballClub> footballclubs, Flux<Country> countries){} 所以我可以通过.block返回list而不是flux，但这不是个好主意。
浏览 21提问于2021-11-16得票数 0
回答已采纳
Flux有collectList()，使用起来非常方便，但是ParallelFlux中没有collectList()，我正在尝试理解在ParallelFlux中省略collectList()的原因。
浏览 137提问于2019-05-02得票数 3
public void test(){
FLux<String> flux = Flux.fromArray收集，如果有操作，操作将永远不会执行？，如果上面的问题是否，会发生什么？。
浏览 3提问于2019-10-04得票数 0
假设我有一个包含许多(数十亿个字符串)的输入Flux，如下所示：有数以十亿计的这样的字符串，它们不会被放入内存中，这就是为什么我想使用反应性的方法。现在，我想要的是通过前3个字符创建一个有序的字符串组：此Flux以HTTP结束，这意味着在"bib“项开始之前必须输出所有"app如果不使用Flux，我就可以使用ordered属性并在它们出现时将
浏览 3提问于2021-10-11得票数 1
回答已采纳
1回答
，一个给定的用户已经参与。我使用的解决方案是调用raceParticipationRepository.findByUserId("userId", PageRequest.of(0,10))，这将返回一个Flux<UserParticipationI应该从响应中收集ids并调用raceRepository.findAllById(ids)。下面是一个代码片段： Flux<Race> findUserRaces(String userId, int
浏览 25提问于2019-03-11得票数 1
回答已采纳
2回答
我是网络流量的新手，我正在尝试用Flux执行多个单点操作。但我觉得我做错了..。这是执行多个Mono并将其收集到列表的最佳方法吗？trxMonoList.add(mainService.getAllTrxByBranchId(branch.branchId)); return Flux.concat}到目前为止，使用上面的代码，我可以这样解释：
branchesiterate 通过branchesList2获取所有的br
浏览 2提问于2020-04-28得票数 3
回答已采纳
我有一个像这个Mono<Stream<String>>的Mono，我想把它转换成像这个Flux<String>那样的通量。在我的初级思想中，我认为应该很简单，因为Mono<Stream<String>>是字符串的“希望”，而Flux<String>也是字符串的“希望”，因此应该有一个简单的操作符来完成转换。我是的新手，所以如果有一个用于这个查询的操作符，就告诉我为什么不可能进行这种操作。Mono<Stream<String
浏览 1提问于2022-05-05得票数 1
回答已采纳
"/cities") return Flux.just(new City("foo"), new City("bar"));该控制器嵌入在一个"hello world“spring应用程序中，它使用和一个简单的主类。类City只有一个属性"name“。不幸的是，第一个失败了，告诉
浏览 6提问于2020-06-08得票数 1
回答已采纳
3回答
假设我同时拥有var a = Flux.just("A", "B", "C")和var b = Flux.just("B", "C", "D")像a.intersect(b)或Flux.intersect(a, b)这样的东西会导致["B", "C"] (的流量)
我找不到任何这样做的操作，有什么想法吗？
浏览 0提问于2020-05-28得票数 4
云服务器
ICP备案
实时音视频
云直播
对象存储
腾讯云开发者
