summaryrefslogtreecommitdiff
path: root/sync/chan_pipeline.go
diff options
context:
space:
mode:
authorDJ O'Leary <dijitol@proton.me>2026-07-14 02:48:22 +0200
committerDJ O'Leary <dijitol@proton.me>2026-07-14 02:48:22 +0200
commit03878d151215277d948b0a1ce31c65d9305d3aa4 (patch)
treeac3136fa6f85f85c54a74e7acbd7c83c325bd594 /sync/chan_pipeline.go
parent783ab544c03991419a7bf7ac033bdf5d34ff9cc3 (diff)
refactor(pkg): move packages that can be imported by others to pkg directory
Diffstat (limited to 'sync/chan_pipeline.go')
-rw-r--r--sync/chan_pipeline.go48
1 files changed, 0 insertions, 48 deletions
diff --git a/sync/chan_pipeline.go b/sync/chan_pipeline.go
deleted file mode 100644
index 6b5f37f..0000000
--- a/sync/chan_pipeline.go
+++ /dev/null
@@ -1,48 +0,0 @@
-package sync
-
-import (
- "context"
- "sync"
-)
-
-func Pipe[IN, OUT any](
- ctx context.Context,
- in <-chan IN,
- transform func(context.Context, IN) OUT,
- workerCount int,
- buffer int,
-) <-chan OUT {
- if in == nil {
- // we only expect this to happen during development
- panic("in-channel is nil")
- }
- if workerCount < 1 {
- workerCount = 1
- }
- if buffer < 0 {
- buffer = 0
- }
-
- wg := sync.WaitGroup{}
-
- out := make(chan OUT, buffer)
-
- for range workerCount {
- wg.Go(func() {
- for v := range OrDone(ctx, in) {
- w := transform(ctx, v)
-
- if !CancelOrSend(ctx, out, w) {
- return
- }
- }
- })
- }
-
- go func() {
- wg.Wait()
- close(out)
- }()
-
- return out
-}