lourenco/mgmt
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

lang: core: iter: Misc formatting fixes

Browse Source 
Also fix up the examples.
This commit is contained in:
James Shubin
2024-07-02 23:49:56 -04:00
parent 7a35bef7ac
commit d1753c592a
4 changed files with 15 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
examples/lang/map-iterator0.mcl
View File

@@ -10,4 +10,4 @@ $out1 = iter.map($in1, $fn)
$t1 = template("out1: {{ . }}", $out1)
test $t1 {}
test [$t1,] {}

2
examples/lang/map-iterator1.mcl
View File

@@ -25,4 +25,4 @@ $out1 = iter.map($in1, $fn)
$t1 = template("out1: {{ . }}", $out1)
test $t1 {}
test [$t1,] {}

2
examples/lang/map-iterator2.mcl
View File

@@ -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,

23
lang/core/iter/map_func.go
View File

@@ -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.