在 akka-http 中使用 handleWebsocketMessage
using handleWebsocketMessage in akka-http
使用akka-http，如何构造一个Flow[Message, Message, _]
传递给只监听传入数据但不写回任何内容的handleWebsocketMessage？无论如何都可以使用水槽吗？因为水槽听起来正是我所需要的。
可以从独立的 Source 和 Sink 中创建 Flow，这正是您在这里需要的。要获得有关它如何表达的更多内部信息，您可能需要阅读 stream composition 文档。
一般来说，您需要创建一个 Flow，它是一个可以处理传入消息的 Sink 和一个从不发出的 Source，这是通过以下方式实现的：
Flow.wrap(Sink.foreach(println), Source.lazyEmpty)(Keep.none)
使用akka-http，如何构造一个Flow[Message, Message, _]
传递给只监听传入数据但不写回任何内容的handleWebsocketMessage？无论如何都可以使用水槽吗？因为水槽听起来正是我所需要的。
可以从独立的 Source 和 Sink 中创建 Flow，这正是您在这里需要的。要获得有关它如何表达的更多内部信息，您可能需要阅读 stream composition 文档。
一般来说，您需要创建一个 Flow，它是一个可以处理传入消息的 Sink 和一个从不发出的 Source，这是通过以下方式实现的：
Flow.wrap(Sink.foreach(println), Source.lazyEmpty)(Keep.none)