我有一个 Web 套接字馈送到 Sink[T， NotUsed] 类型的接收器中，
我需要将其馈送到 Source[T， NotUsed] 类型的源中。这个想法是，我通过 websocket 连接到某个源，并通过源通过 rpc 流式传输在此接收器上接收的数据。
即 Web 套接字 -> sink[T， NotUsed] -> source[T， NotUsed]。
谢谢。
你可以
看看
Flow.fromSinkAndSource(...)
https://doc.akka.io/docs/akka/current/stream/operators/Flow/fromSinkAndSource.html。
您是否尝试过使用Sink.asPublisher[Message](fanout = false)然后使用Source.fromPublisher(publisher)？