Akka流：将新的发布者/订阅者附加到流

Question

我正在构建一个Akka应用程序，并希望向外部消费者公开一些参与者的FSM状态转换。（最终目标是能够将状态转换消息推送到websocket，以便可以实时查看。）

    val orderFlow: Flow[String, String, NotUsed] = {
        val (sink, source) = MergeHub.source[String](16)
            .toMat(BroadcastHub.sink(256))(Keep.both).run()
        Flow.fromSinkAndSource(sink, source)
    }

Answer 1

对于这个特殊的问题，我不会使用akka-stream。您描述的组播pub-sub类型更适合于原始的actor消息传递和EventStream。

我是akka-stream的超级粉丝，但在这种情况下，我认为你是试图通过一个圆孔适合一个方形的钉子。