Verified Moving all legacy quacker source code from github to cgitHEADmain

1 files changed, 53 insertions, 0 deletions

diff --git a/pipeline/example_test.go b/pipeline/example_test.go
new file mode 100644
index 0000000..e322529
--- /dev/null
+++ b/pipeline/example_test.go
@@ -0,0 +1,53 @@
+package pipeline_test
+
+import (
+        "context"
+        "fmt"
+        "sort"
+
+        "git.sangtran.io.vn/quacker.git/pipeline"
+)
+
+func ExampleRun() {
+        input := make(chan int, 5)
+        for i := 1; i <= 5; i++ {
+                input <- i
+        }
+        close(input)
+
+        out := pipeline.Run(context.Background(), input,
+                pipeline.Filter(func(v int) bool { return v%2 == 0 }),
+                pipeline.Map(1, func(_ context.Context, v int) (int, bool) {
+                        return v * 10, true
+                }),
+        )
+
+        var results []int
+        for v := range out {
+                results = append(results, v)
+        }
+        sort.Ints(results)
+        fmt.Println(results)
+        // Output: [20 40]
+}
+
+func ExampleSink() {
+        input := make(chan string, 3)
+        input <- "hello"
+        input <- "world"
+        input <- "!"
+        close(input)
+
+        var collected []string
+        out := pipeline.Run(context.Background(), input,
+                pipeline.Sink(1, func(_ context.Context, v string) {
+                        collected = append(collected, v)
+                }),
+        )
+
+        for range out {
+        }
+
+        fmt.Println(collected)
+        // Output: [hello world !]
+}