我很难得到一个akka.stream.scaladsl.SubFlow编译的implicit class。我的测试代码: val subFlow = Source(List("1", "2", "3"))
val richSubFlow = new SideEffectfulSubFlowOps* Unlike [[SubFlow.alsoTo]] and [[SubFlow.wireTap]], this operation
在Spring批处理作业中,我有两个业务操作,A和B,每个操作有几个步骤(1、2、3)。我希望并行运行A1和B1,当两者都结束时,我想并行地运行A2和B2: A1-B1 in parallel A2-B2 in parrallel A3-B3 in parrallel我试过一些东西:public Job test() {
SimpleFlow splitFlow = new FlowBuilder<SimpleFlow>("Se