误导了flatMapSequentialDelayError的项目反应堆文档图像,还是...?

马丁·穆查(Martin Mucha)

我已经在图像上多次看到它,只是根本不了解它。这是javadoc:

https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#flatMapSequentialDelayError-java.util.function.Function-int-int-

有问题的图片(对不起,我无法直接显示它)

https://projectreactor.io/docs/core/release/api/reactor/core/publisher/doc-files/marbles/flatMapSequentialWithConcurrencyAndPrefetch.svg

有人可以解释,为什么会有1个红色方框?为什么内部Flux这么快完成?基于(在原始助焊剂中)是否仍发出紫色?我想念什么?

迈克尔·贝瑞

据我所知图像是正确的。

我想念什么?

您似乎以为该flatMapSequential()调用会以某种方式影响通量的结束时间或发出元素的时间-红色通量仅在一个元素之后终止,而其他元素持续两个。事实并非如此-这只是当您调用flatMapSequential()以这种方式运行的磁通时发生的情况的一个示例

如果有帮助,请想象他们是3个通过查询返回数据库记录的流量。先订阅绿色通量,然后返回结果(但未完成,因为还有另一条记录要返回。)然后订阅红色通量,返回结果并完成(因为只有一条记录然后订阅紫色流,返回一个结果,然后绿色和紫色流返回另一结果,然后全部完成。

在这种情况下,如果红色助焊剂没有完成,那么直到绿色或红色助焊剂中的至少一个完成后,紫色助焊剂才会被订阅(因为在这种情况下,最大并发率为2)。此示例的行为方式可以使示例简洁明了,并在视觉上展示“顺序”和“最大并发”元素。

本文收集自互联网,转载请注明来源。

如有侵权,请联系[email protected] 删除。

编辑于
0

我来说两句

0条评论
登录后参与评论

相关文章

来自分类Dev

误导了flatMapSequentialDelayError的项目反应堆文档图像,还是...?

来自分类Dev

项目反应堆背压问题

来自分类Dev

无法在反应堆中删除要删除的项目

来自分类Dev

弹簧整合反应堆

来自分类Dev

反应堆测试失败

来自分类Dev

Maven错误:“反应堆项目列表中没有SNAPSHOT项目。”

来自分类Dev

重用项目反应堆发布者Flux / Mono是否被视为最佳实践?

来自分类Dev

扭曲的ExtendSelected反应堆错误

来自分类Dev

流星JS $近反应堆

来自分类Dev

扭曲的Python暂停/推迟反应堆

来自分类Dev

从线程运行扭曲反应堆

来自分类Dev

反应堆lmax线程转储

来自分类Dev

反应堆取消订阅的方式

来自分类Dev

如何使用flatMap()在反应堆语境?

来自分类Dev

与反应堆抛出异常的正确方法

来自分类Dev

WebFlux(反应堆)中的文件处理

来自分类Dev

流星JS $近反应堆

来自分类Dev

在iPython中运行扭曲反应堆

来自分类Dev

反应堆v1.xx与反应堆v2.xx

来自分类Dev

工程反应堆:设计一个反应API

来自分类Dev

在反应堆项目中不再存在的Maven模块在Jenkins生成报告中显示为“未运行”

来自分类Dev

在Maven中,什么时候项目会成为反应堆的一部分?

来自分类Dev

如何知道反应堆是否在python中运行?

来自分类Dev

在Spring中使用哪种“ EventBus”?内置反应堆,Akka?

来自分类Dev

我如何从反应堆运行state.sls

来自分类Dev

替代扭曲的while循环,不会阻塞反应堆线程

来自分类Dev

R带条件面板和反应堆的Shiny模块

来自分类Dev

实现像数据反应堆这样的系统

来自分类Dev

从单在工程反应堆处理可选值