1 files changed, 35 insertions, 0 deletions

diff --git a/fanin/example_test.go b/fanin/example_test.go
new file mode 100644
index 0000000..0edae08
--- /dev/null
+++ b/fanin/example_test.go
@@ -0,0 +1,35 @@
+package fanin_test
+
+import (
+        "context"
+        "fmt"
+        "sort"
+
+        "git.sangtran.io.vn/quacker.git/fanin"
+)
+
+func ExampleNewFanIn() {
+        fi, _ := fanin.NewFanIn[int]()
+
+        ch1 := make(chan int, 2)
+        ch1 <- 1
+        ch1 <- 2
+        close(ch1)
+
+        ch2 := make(chan int, 2)
+        ch2 <- 3
+        ch2 <- 4
+        close(ch2)
+
+        fi.Add(ch1)
+        fi.Add(ch2)
+
+        var results []int
+        for v := range fi.Run(context.Background()) {
+                results = append(results, v)
+        }
+
+        sort.Ints(results)
+        fmt.Println(results)
+        // Output: [1 2 3 4]
+}