(seq dag.Seq, post func(dag.Seq) dag.Seq)
| 74 | } |
| 75 | |
| 76 | func Walk(seq dag.Seq, post func(dag.Seq) dag.Seq) dag.Seq { |
| 77 | for _, op := range seq { |
| 78 | switch op := op.(type) { |
| 79 | case *dag.ForkOp: |
| 80 | for k := range op.Paths { |
| 81 | op.Paths[k] = Walk(op.Paths[k], post) |
| 82 | } |
| 83 | case *dag.ScatterOp: |
| 84 | for k := range op.Paths { |
| 85 | op.Paths[k] = Walk(op.Paths[k], post) |
| 86 | } |
| 87 | } |
| 88 | } |
| 89 | return post(seq) |
| 90 | } |
| 91 | |
| 92 | func walkEntries(seq dag.Seq, post func(dag.Seq) (dag.Seq, error)) (dag.Seq, error) { |
| 93 | for _, op := range seq { |
no outgoing calls
no test coverage detected