使用akka-http，我怎样才能构造一个只监听传入数据但不写回任何东西的Flow[Message, Message, _]
传递给它？handleWebsocketMessage无论如何都可以使用接收器吗？因为 Sink 听起来像是我需要的。
问问题
499 次
1 回答
4
Flow可以从独立的Sourceand中创建一个Sink，这就是您在这里所需要的。要获取有关它如何使用单词的更多内部信息，您可能需要阅读流组合文档。
通常，您需要创建一个 Flow 使其成为可以处理传入消息的 Sink 和从不发出的 Source，这是通过以下方式实现的：
Flow.wrap(Sink.foreach(println), Source.lazyEmpty)(Keep.none)
于 2015-08-20T16:53:14.310 回答