使用akka-http，如何构造一个Flow[Message, Message, _]
传递给仅监听传入数据但不写回任何内容的handleWebsocketMessage？无论如何都可以使用 Sink 吗？因为 Sink 听起来正是我所需要的。
最佳答案
可以从独立的Source和Sink创建一个Flow，这正是您在这里所需要的。要获得有关如何表达的更多内部信息，您可能需要阅读 stream composition文档。
一般来说，您需要创建一个 Flow，使其成为一个可以处理传入消息的 Sink 和一个从不发出消息的 Source，这是通过以下方式实现的:
Flow.wrap(Sink.foreach(println), Source.lazyEmpty)(Keep.none)
关于scala - 在 akka-http 中使用handleWebsocketMessage，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/32121564/