当前位置: 首页 > 知识库问答 >
问题:

将mono/flux压缩到另一个,这取决于我拥有的那一个

黄弘新
2023-03-14

我想压缩两个monos/Flux,但第二个(我将压缩的那个)与我已经拥有的第一个不同
例如:

//...

    fun addGroup(
        input: GroupInput
    ): Mono<Group> = Mono.just(Group(title = input.title, description = input.description))
        .flatMap { g -> groupsRepository.save(g) } // Gives me back the new db ID
        .zipWith(Mono.just(GroupMember(g.id /* <-- ??*/, input.ownerId, true)))
        //...

// ...

可能吗?

共有1个答案

井浩思
2023-03-14

我会说不。你只能压缩那些可以并行运行的东西。

 类似资料:
  • 有可能做类似下面代码的事情吗?我有一个服务进行API调用,另一个返回值流。我需要用API调用返回的值修改每个值。 我尝试过用。repeat()处理单声道,它可以工作,但是每次有新的流量值时它都会调用方法,而且是API调用,所以不好。 有可能吗?

  • 我是Spring Reactive Project的新手。使用中出现问题。我有两个Flux,一个有更多元素,例如 还有人喜欢 如何获取bigFlux中未出现在smallFlux中的元素?我不知道该用哪个接线员。 我尝试过: 但这并不明智,我通过复杂的操作获得了smallFlux,例如查询数据库、平面图操作。这样,bigFlux中有多少元素,这些操作将重复多少次。 事实上,小通量是通过这种方式获得的

  • 问题内容: 我有两个要素。第一个包含国家(例如美国,加拿大,英国,俄罗斯,波兰…),第二个国家被隐藏, 仅 包含美国和加拿大(例如纽约,洛杉矶,芝加哥…或渥太华,温哥华)的城市,萨里…) 如果用户从第一个中选择“加拿大”或“美国” ,则第二个应显示并允许他选择城市。 有可能吗?我使用Ajax和JQuery Validation表单访问了许多网站,但没有找到类似的来源。 谢谢。 问题答案: 侦听选择

  • 问题内容: 嗨,我有一个产生AAR的Android库项目。 一切都很好,但是当我在另一个项目中使用AAR时,出现此错误: AAR使用了毕加索,生成毕加索的依赖项是否也可以导出? 问题答案: 如何设置本地Maven存储库。 警告:以下食谱工作,但也许可以使用改善,因为我是 远 从Maven的专家。去年,我在CWAC库中采用了这种方法。 步骤#1:在您的图书馆专案档案中加入您的 区块。还添加和语句以提

  • 我需要在没有中间存储的情况下读写压缩(GZIP)流。目前,我使用Spring

  • 我有这个场景。我有一个分页的API,它给我过去12个月的数据。API的响应是这样的: 现在我必须收集所有的数据,然后计算所有的总和,并返回为