流
「Akka Streams」使对类型安全的消息处理管道建模变得容易。对于类型化的 Actors,可以在不丢失类型信息的情况下将流连接到 Actors。
从这些工厂方法和源可以与来自原始模块的原始 Akka 流构建块混合和匹配。
- 注释:此模块已准备好用于生产,但仍标记为「」。这意味着 API 或语义可以在没有警告的情况下进行更改,但这些更改将在 Akka 2.6.0 中收集并执行,而不是在 2.5.x 补丁版本中执行。
有两个sink
可接受类型化的。要将流中的所有消息发送给 Actor 而不考虑反压力(backpressure
),请使用「ActorSink.actorRef」。
英文原文链接:.