文章/答案/技术大牛

发布

社区首页 >问答首页 >在akka-http中使用handleWebsocketMessage

问在akka-http中使用handleWebsocketMessage
EN

Stack Overflow用户

提问于 2015-08-20 14:53:10

回答 1查看 513关注 0票数 2

使用akka-http，我如何构造一个Flow[Message, Message, _]来传递给只监听传入数据而不写任何东西的handleWebsocketMessage？反正可以用水槽吗？因为水槽听起来像我所需要的。

回答已采纳

发布于 2015-08-20 16:53:14

可以从独立的Flow和Sink创建一个Sink，这正是您在这里所需要的。要获得更多关于如何使用单词的内部信息，您可能需要阅读流组成文档。

通常，您需要的是创建一个流，使其能够处理传入的消息，并创建一个永不发出的源，这是通过以下方法实现的：

Flow.wrap(Sink.foreach(println), Source.lazyEmpty)(Keep.none)

票数 4

页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持

原文链接：

https://stackoverflow.com/questions/32121564

复制

相似问题

问在akka-http中使用handleWebsocketMessageEN