我使用Akka创建了这个groupBy -> map -> mergeSubstreamsWithParallelism示例。在我所做的过程中,它说groupBy将创建关于我传递给它的参数的X子流,然后我必须将子流合并到一个流中。因此,我理解map操作符是并行运行的。是那么回事吗?如果是这样的话,为什么我可以在下面的代码中看到同一个线程执行map操作符: "I love Akka streams&quo
为什么我要得到这个错误,我需要做些什么来测试下面的流类型?我所拥有的用例是一个连续的(永不结束的)元素流,我需要将它们分割成子流,然后我可以在每个传入消息的情况下并行处理这些流。例如,有办法清理子流吗?因为这是一个永无止境的流,所以可能会积累大量需要清理的子流。Test-System-akka.actor.default-dispatcher-3 BEFORE Wid(1,1)
Test-System-akka.ac