Akka.网络流排序(网络上的流排序)



Akka.net Streams是否保留元素的输入顺序?如果是这样,那么在网络上使用响应式流(使用流参考)时是否也适用?

Akka的当前版本。正在使用的流是1.4.39

不幸的是,我无法在Akka.net文档中找到一个明确的答案。

在进一步阅读之后,我找到了我的答案。

https://getakka.net/articles/streams/basics.html stream-ordering

在Akka流中,几乎所有的计算阶段都保持元素的输入顺序。这意味着如果输入{IA1,IA2,…,伊恩}"cause"输出{OA1, OA2,…,OAk},输入{IB1,IB2,…, IBm}"cause"输出{OB1, OB2,…,OBl}和所有IAi发生在所有IBi之前那么OAi发生在OBi之前

这个属性甚至被像SelectAsync这样的异步操作所支持,但是存在一个叫做SelectAsyncUnordered的无序版本,它不保持这种排序。

相关内容

  • 没有找到相关文章

最新更新