data class Item(val value: Int)
item = Item(item.value * it.value) } 但是当有Item和Transformation的Flux
浏览 20提问于2019-03-14得票数 0
回答已采纳
1回答
我已经编写了一个应用程序，服务器端应用了事件源模式，所有传入命令都按照反应堆顺序处理。我从客户关系处得到这些命令。唉，我的Netty管道发布命令时不尊重反应性合同。反应堆Netty可能是解决方案的一部分，因为它强制将反应性合同传递给Netty管道。我如何动态合并几个通量在一个？如何循环通过传入的通量？
浏览 0提问于2018-10-13得票数 0
回答已采纳
我有两个对象，每个对象中都包含列表，我的整个spring引导项目都使用项目反应堆结构。我是否应该使用通量内的java流或单映射操作来遍历和操作数据？pageField.setModifiedOn(Instant.now(Clock.systemUTC())); return pageField;或者我应该在通量的映射操作中使用
浏览 0提问于2019-07-25得票数 3
回答已采纳
这些过滤的Flux实例中有很多是并发存在的。我想要的是允许我指定一个输入通量和一个键函数，然后(反复)为任何给定的键值获得一个输出流。每个子通量的行为就像上面过滤的那样，但是
浏览 3提问于2020-09-10得票数 2
1回答
如何使用反应堆处理历史数据？
、、、、
假设我有两个历史事件的来源，每个来源的事件都是按时间顺序排列的。
如何使用反应堆合并这些源，使合并后的通量中的事件按时间顺序发出？在RxNET中，可以使用Observable.Generate()和HistoricalScheduler的组合从历史事件的源头创建Observable，以便根据事件发生的时间(如详细的)排定排放，但我无法在反应堆中找
浏览 29提问于2022-01-03得票数 0
是否有可能使用Wiremock来模拟反应式后端。我想要做的是让Wiremock返回分块响应，但每个分块都应该是一个有效的json字符串(模仿反应堆通量类型的响应)。这个场景是这样的，我有一个后端发送一个我可以使用的json对象流。可以将每个json字符串编组到POJO中，而不需要跟踪状态(之前出现的块)。通过网络传输的每个数据块可以有不同
浏览 4提问于2021-11-06得票数 0
1回答
我使用的是项目反应堆和。(我基本上有一个对象A的流；对于每一个对象A，我把它平面地映射成对象B的流，然后用它做一个新的通量。)我只想明白：
什么是预取？它是否只适用于最初的请求？(也就是说，如果我将其设置为1，如果项目反应堆发现1太小，它<
浏览 0提问于2019-06-19得票数 9
回答已采纳
Mermaid",}
获取每个字符名称的唯一将响应从“卡通-db”映射到内部表示，即控制器返回值。我有一个卡通人物名称的列表，对于其中的每一个，我需要调用getCartoonCharacterIdbyName(String na
浏览 1提问于2020-03-25得票数 2
回答已采纳
1回答
链接多个发布者转换响应
、、、、
我想在每一次通量事件之后连锁一次。mono发布者将需要由通量发布的每个事件的信息。响应应该是具有通量事件和单次响应数据的通量。 }我的主要关切是
浏览 3提问于2021-03-16得票数 0
回答已采纳
1回答
对于使用fluidcontent的复杂TYPO3项目，我正在寻找一个工具，它向我展示了以下信息：
如何在typo3项目中实现这个库是最明智的方法？我的想法是，开发一个扩展，读取流畅的内容模板，并以示例显示前端插件中的信息。但我不知道读出像“用过的部分”或“用过的通量形
浏览 7提问于2016-07-08得票数 0
1回答
我有一个提供辐射度的卫星数据，我用它来计算通量(使用表面和云信息)。现在使用回归方法，我可以得到一个将辐射和通量联系起来的数学模型，并且可以用来预测新辐射度值的通量，而不需要其他新的输入。是否可以使用决策树或回归树来执行相同的操作？在回归中，有一个连接因变量和自变量的数学方程。使用决策树，您如何开发这样的模型？
浏览 0提问于2013-07-13得票数 0
6回答
检测和固定溢出
、、
每隔一段时间，都会有一些预测的粒子通量峰值通过它，这是可以的。不好的是，这些通量通常会超过缓冲器存储它们的能力；因此，会发生溢出。在图表上，它们看起来像通量突然下降，并开始再次增长。我们在数据处理设备上使用python；检测器本身使用的技术非常晦涩(就像它是由一个完全不相关的第三方开发的)，但是它绝对是简单的，即没有运行一个“真正的”OS，只是一些低级的东西来记录
浏览 9提问于2009-05-29得票数 0
回答已采纳
反应堆错误处理文档()指出，错误处理操作符不允许原始序列继续。
在了解错误处理操作符之前，必须记住，反应序列中的任何错误都是终端事件。即使使用了错误处理操作符，也不会让原始序列继续。相反，它将onError信号转换为新序列(回退序列)的开始。换句话说，它取代了它上游的终止序列。还有其他方法让原始序列(源流)继续对所有操作符起作用吗？我不希望在出现错误( onErrorResume行为)时替换源通量--我只想忽略问题元素&继续使用源通量。编辑1(我的</
浏览 3提问于2021-10-09得票数 4
回答已采纳
我想做以下类似的事情，在下一次调用中使用来自上一次调用的结果，使用Project反应堆对同一服务进行调用。(Step step in steps) current = new Message(step, next);}每个“步骤”的(在一个通量中)
为该步骤和最后一个结果创建一条消息(null )。c.将最后一条消息设置为此结果，以便它可以在1a中
浏览 1提问于2020-03-26得票数 1
回答已采纳
我注意到不建议使用这样的提取器Mono.toFuture()，Flux.collectList()，因为它们会阻塞流。
我不太确定“阻塞”是怎么回事。就像在下面的代码中一样，我知道Flux.collectList()会等待所有的项目完成，是像某个线程一直在等待，还是仅仅是最后一个线程完成了.collectList()的事情？Mono.toFuture()也会阻止它，它将立即返回一个“未来”(当onNext()或onComplete()发生时，它将是可用的)，还是会返回到onNext()或onComplete()发生为止？
浏览 5提问于2021-10-09得票数 1
回答已采纳
2回答
我希望我的应用程序对来自数千个不同客户端的UDP事件做出反应。每个客户端每5-10秒发送1-10个UDP数据包。每个包都会并且应该很快地被处理(主要是在内存和小的计算中，帮助进行redis，只是偶尔的DB调用)。将不会将数据返回给来电者。
我在春天实现了反应堆，就像他们在上描述的那样。，我想要高通量产出？int-ip:udp-入站通道适配器的内部工作原理是什么?在将消息传递给反应堆
浏览 1提问于2013-11-03得票数 0
回答已采纳
我正在尝试构建一个数据集，其中包括道路连接、它们的几何形状以及有关道路的信息，如车道数、功能类别和日均交通量。我一直无法确定这里是否有一个API来检索每个道路连接的年平均日交通量。我已经找到了一个获取一般道路连接信息的接口，其中不包括交通：我希望得到的<
浏览 2提问于2019-11-07得票数 2
1回答
我有两种类型的用户isEmployer和isCandidate。当我登录时，我的应用程序应该检查用户的role，然后加载批准路线加上重定向到适当的登陆页面。这一切似乎都是正确的，但是路由只在login或registration上重定向，如果用户角色isCandidate的话。但是，如果用户isEmployer页面没有改变，那么导航条中的导航选项就会改变。
我看不出我在这里错过了什么。有什么帮助吗？
浏览 2提问于2017-11-10得票数 1
回答已采纳
我正在将代码从命令式迁移到反应性java。例如，假设我有Employee和Department mongo集合，并使用反应性mongo存储库从数据库中获取结果。webclient (empId, managerId, deptId, deptName);
浏览 0提问于2019-07-17得票数 0
回答已采纳
云服务器
ICP备案
云直播
对象存储
实时音视频
腾讯云开发者
