fanin/example_test.go


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
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]
}