我正在尝试Akka Stream API,但是我不知道为什么它会抛出一个java.lang.IllegalArgumentException。$tilde$greater(Graph.scala:1730)[info] at akka.stream.scaladsl.GraphApply.create$(GraphApply.scala:41)
[info] at a
我有一个akka流,其中我有一个ADT的形式。This Message Handler流和That Message Handler流。我有一个接受类型Message的入口流。 为了创建拆分,我有以下分区程序。我对分区函数有以下定义。1
new FanOutShape2(partitioner.in, partitioner.out(0).outlet, parti
事实上,在仔细阅读他们的文档后,我已经找到了与我的目标相关的页面,即this和this。上面的代码将返回一个将由akka的websocket指令使用的流:akka.http.scaladsl.server.Directives.handleWebSocketMessages(/* FLOWGOES HERE */),这意味着只要我为它提供处理程序,akka代码本身就会为我实现这个流</em