Akka stream 的 SubstreamCancelStrategy 的作用
Akka stream 的 SubstreamCancelStrategy 是用来控制子流(substream)取消的策略。SubstreamCancelStrategy 有以下三种策略:
-
背压(backpressure):当主流(main stream)收到取消信号时,所有子流都会收到取消信号。
-
Immediate:当主流收到取消信号时,所有子流会立即停止,不会再处理任何元素。
-
Completion:当主流完成时,所有子流也会完成。如果主流收到取消信号,所有子流也会收到取消信号。
SubstreamCancelStrategy 可以通过调用 substreamCancelStrategy 方法来设置。默认情况下,SubstreamCancelStrategy 为背压策略。
原文地址: https://www.cveoy.top/t/topic/vHJ 著作权归作者所有。请勿转载和采集!