From 02123df8cc15896f97c1580e49d8e2a991e37ddd Mon Sep 17 00:00:00 2001 From: sangtran Date: Thu, 3 Sep 2026 23:10:33 +0700 Subject: Moving all legacy quacker source code from github to cgit --- fanin/example_test.go | 35 +++++++++++++++++++++++++++++++++++ 1 file changed, 35 insertions(+) create mode 100644 fanin/example_test.go (limited to 'fanin/example_test.go') 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] +} -- cgit v1.3.1