パイプライン実装をchanでなくiterを使えないか

[ddddddO]

ただ、ビルド時かな、環境変数で機能をonにする必要がある
iter実装難しそうだけど、試してみたい
既存のchan使った実装とパフォーマンスの比較もしたい

[ddddddO]

https://github.com/mattn/go-for-range-experiment-example/

こちらも実装の参考にしたい

[ddddddO]

試してみた
https://github.com/ddddddO/work/blob/master/go/cmd/iter/main.go

いけそうにおもう

各ステージのエラーもSeqの型の中に入れれば良さそう？いや？

対応箇所は内部関数なので、iter関数内でerr時にpanic → 呼び出し元でrecoverでerrをハンドリングでいけそう？

[ddddddO]

エラーハンドリング可能なパイプラインのサンプル実装
https://github.com/ddddddO/work/blob/2a9b38da3bdab3f1bf3691b9a5532834f7e9b462/go/cmd/iter/main.go#L245-L264

これでやりたいことができそう
あとは時間あるときとにやる

[ddddddO]

迷う
サンプル実装したけどシュッとできそう感もある、どうしよう

今あまり手を出さないほうがいいかも。本格的にgo本体に導入決まってからのほうが手戻りなさそう

[ddddddO]

実況スレ
https://twitter.com/ddddddOpppppp/status/1755938673634550070?t=E4eq1W3_rmHHs8S6rJ9iDA&s=19

[ddddddO]

gtree/pipeline_tree.go

Lines 78 to 82 in c1c007f

	splitStream, errcsl := split(ctx, r)
	rootStream, errcr := newRootGeneratorPipeline().generate(ctx, splitStream)
	growStream, errcg := t.grower.grow(ctx, rootStream)
	errcs := t.spreader.spread(ctx, w, growStream)
	return t.handlePipelineErr(ctx, errcsl, errcr, errcg, errcs)

でいちいち変数にとって渡す、みたいにしなくてよくなって1行で書けそうだし、chanでないから、入力値の順番で処理が保証されるから、やりたい度は高い

↓な感じになる、きれい

for err := range spread(grow(generate(split(ctx, r)))) {
    if err != nil {
        return err    
    }
}
return nil

[ddddddO]

パイプライン実装以外でもiter実装できそう
ref:

gtree/root_generator.go

Line 27 in c1c007f

func (rg *rootGeneratorSimple) generate() ([]*Node, error) {