我有一个Web套接字，它连接到Sink[T，NotUsed]类型的接收器，我需要将它连接到Source[T，NotUsed]类型的源。即Web套接字-〉接收器[T，未使用] -〉源[T，未使用]。
vktxenjb1#
你可以看看Flow.fromSinkAndSource(...)https://doc.akka.io/docs/akka/current/stream/operators/Flow/fromSinkAndSource.html。
Flow.fromSinkAndSource(...)
rvpgvaaj2#
您是否尝试过先使用Sink.asPublisher[Message](fanout = false)，然后再使用Source.fromPublisher(publisher)？
Sink.asPublisher[Message](fanout = false)
Source.fromPublisher(publisher)
2条答案
按热度按时间vktxenjb1#
你可以看看
Flow.fromSinkAndSource(...)https://doc.akka.io/docs/akka/current/stream/operators/Flow/fromSinkAndSource.html。
rvpgvaaj2#
您是否尝试过先使用
Sink.asPublisher[Message](fanout = false)，然后再使用Source.fromPublisher(publisher)？