Ruu*_*Pul 11 scala akka reactive-streams akka-stream
我正在玩Akka Stream,我试图在实现后弄清楚它的灵活性.
一种方法是使用低级反应流API:http: //doc.akka.io/api/akka-stream-and-http-experimental/1.0-M3/#akka.stream.scaladsl.PublisherSource
但是,您需要定义这些点以进行发布或订阅.有没有办法发布或订阅任意物化流程图节点？这应该是可能的,因为物化流程图只不过是一组参与者.
例如:首先,部署流程图1:A~> B~> C.
然后,部署流程图2和3:D~> BB~> E
Kon*_*ski 10
不可能完全动态地改变流处理流水线的结构.我们确实预见到某些类型的动态处理阶段(例如"可能来来往往的工作人员的扇出"),但一般来说,流和流处理管道在实现之前应该有一个明确的布局.这也是有意义的,因为akka-streams和反应流一般使用的背压机制- 它必须在内部进行仔细管理,并且允许任意交互不是这种流模型的设计目的.
如果你想要任意互动,演员应该更适合你.如果你想拥有一个可以利用外部信号来控制处理流水线的处理元素,那么它将是一个特殊的元素,用于接收这些信号,而不仅仅是任何元素.
自从我发布这篇文章以来,我们添加了一些动态功能,这可能是登陆本网站的人们感兴趣的,最值得注意的是MergeHub和BroadcastHub
请注意,由于编写稳定版本的Akka Streams是2.4.16.