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

Spring WebFlux反应器-更新Flux中的对象

百里胜泫
2023-03-14

给出以下方法:

Flux<Person> getAllPerson(Criteria criteria) 
getAllPerson(criteria)
                .map(person -> person.setLastUpdated(new Date())
getAllPerson(criteria)
                .map(person -> {
                     person.setLastUpdated(new Date())
                     return person;
                 });

共有1个答案

龚弘业
2023-03-14

您可以使用doonnext运算符来执行这种副作用操作。

虽然,通常保持Person类不可变是一种更好的方法,当您需要修改某些内容时,只需创建它的副本,在这种情况下,您将能够按照预期使用map运算符。

 类似资料:
  • 我在JS对象(不是数组)中有一个

  • 有没有办法强迫groupBy()生成的流量在一段时间后完成(或者类似地,限制“开放”组的最大值),而不管上游的完整性?我有以下内容: 我遇到了通量挂起的情况,假设是因为组的数量大于平面映射的并发性。我可以增加flatMap的并发性,但是没有简单的方法来判断最大可能大小是多少。相反,我知道Foo是按Foo分组的。key将在时间/发布顺序上彼此接近,并且宁愿在groupBy Flux与flatMap并

  • 我正在使用SpringWebSockets,我想从存储库返回一个项目列表 我怎么能在WebSocket会话中发送此列表 这是如何将项目列表发送到websocket的处理程序方法

  • Java文档说明如下: 仅当发布者为该特定最后一个值提供的时间窗口期间没有发出新值时,才从该通量中发出最后一个值。 然而,我发现上述描述令人困惑。我在gitter聊天中看到它类似于RxJava中的debounce。有人能举例说明吗?在彻底搜索之后,我在任何地方都找不到这个。

  • 问题内容: 在这里,我尝试设置为’hello’,然后打印它,但是状态似乎为空。当我刚刚使用更新状态时怎么办?设置为全局变量。 问题答案: 从reactjs文档中: 不会立即变异,但会创建待处理的状态转换。调用此方法后进行访问可能会返回现有值。 https://facebook.github.io/react/docs/component- api.html 您可以做的是将状态更新后传递给回调函数:

  • 我当前的尝试在下面,但这只打印一个值。我希望采样定期继续,以便每秒打印一个值。如何做到这一点?