我从更新
com.typesafe.akka:akka-stream-experimental_2.10:1.0-M3
至
com.typesafe.akka:akka-stream-experimental_2.10:1.0-M4
但是没有像 UndefinedSource、UndefinedSink、BlackholeSink、SubscriberSink、OnCompleteSink 等类。
没有文档说明为什么要删除它以及现在要采用哪种方法而不是这些类。
虽然在这个版本的文档中我仍然看到 UndefinedSource 的概念
http://doc.akka.io/docs/akka-stream-and-http-experimental/1.0-M4/scala/stream-io.html
我们使用 PartialFlowGraph 构建 Flow 的方式在 Constructing Sources, Sinks and Flows from Partial Graphs 中有详细解释，但是基本概念相当简单——我们可以在 Flow 中封装任意复杂的逻辑，只要它暴露相同的接口，这意味着只暴露一个 UndefinedSink 和一个 UndefinedSource，它们将被连接到 TCP 管道。在此示例中，我们使用 Concat 图处理阶段来注入初始消息，然后使用回显处理程序继续处理所有传入数据。您应该使用这种在 Flows 中封装复杂逻辑并将其附加到 StreamIO 的模式，以实现您的自定义和可能复杂的 TCP 服务器。
似乎是文档错误或现在需要一些额外的依赖项