diff --git a/examples/lang/map-iterator0.mcl b/examples/lang/map-iterator0.mcl index 316555ca..9585e0d4 100644 --- a/examples/lang/map-iterator0.mcl +++ b/examples/lang/map-iterator0.mcl @@ -10,4 +10,4 @@ $out1 = iter.map($in1, $fn) $t1 = template("out1: {{ . }}", $out1) -test $t1 {} +test [$t1,] {} diff --git a/examples/lang/map-iterator1.mcl b/examples/lang/map-iterator1.mcl index 362d32a8..70bf1df7 100644 --- a/examples/lang/map-iterator1.mcl +++ b/examples/lang/map-iterator1.mcl @@ -25,4 +25,4 @@ $out1 = iter.map($in1, $fn) $t1 = template("out1: {{ . }}", $out1) -test $t1 {} +test [$t1,] {} diff --git a/examples/lang/map-iterator2.mcl b/examples/lang/map-iterator2.mcl index 09e7ff46..93e562ac 100644 --- a/examples/lang/map-iterator2.mcl +++ b/examples/lang/map-iterator2.mcl @@ -37,7 +37,7 @@ $out1 = iter.map($in1, $fn) $t1 = template("out1: {{ . }}", $out1) -test $t1 {} +test [$t1,] {} file "/tmp/mgmt/map" { state => $const.res.file.state.exists, diff --git a/lang/core/iter/map_func.go b/lang/core/iter/map_func.go index 6fd7d754..486663dd 100644 --- a/lang/core/iter/map_func.go +++ b/lang/core/iter/map_func.go @@ -343,24 +343,25 @@ func (obj *MapFunc) Stream(ctx context.Context) error { func (obj *MapFunc) replaceSubGraph(subgraphInput interfaces.Func) error { // Create a subgraph which splits the input list into 'n' nodes, applies - // 'newFuncValue' to each, then combines the 'n' outputs back into a list. + // 'newFuncValue' to each, then combines the 'n' outputs back into a + // list. // // Here is what the subgraph looks like: // // digraph { - // "subgraphInput" -> "inputElemFunc0" - // "subgraphInput" -> "inputElemFunc1" - // "subgraphInput" -> "inputElemFunc2" + // "subgraphInput" -> "inputElemFunc0" + // "subgraphInput" -> "inputElemFunc1" + // "subgraphInput" -> "inputElemFunc2" // - // "inputElemFunc0" -> "outputElemFunc0" - // "inputElemFunc1" -> "outputElemFunc1" - // "inputElemFunc2" -> "outputElemFunc2" + // "inputElemFunc0" -> "outputElemFunc0" + // "inputElemFunc1" -> "outputElemFunc1" + // "inputElemFunc2" -> "outputElemFunc2" // - // "outputElemFunc0" -> "outputListFunc" - // "outputElemFunc1" -> "outputListFunc" - // "outputElemFunc1" -> "outputListFunc" + // "outputElem0" -> "outputListFunc" + // "outputElem1" -> "outputListFunc" + // "outputElem2" -> "outputListFunc" // - // "outputListFunc" -> "subgraphOutput" + // "outputListFunc" -> "subgraphOutput" // } const channelBasedSinkFuncArgNameEdgeName = structs.ChannelBasedSinkFuncArgName // XXX: not sure if the specific name matters.