Skip to content

Instantly share code, notes, and snippets.

@campoy
Created January 29, 2018 07:10
Show Gist options
  • Save campoy/c19e2852b66c7d36cf28ac31b877c05b to your computer and use it in GitHub Desktop.
Save campoy/c19e2852b66c7d36cf28ac31b877c05b to your computer and use it in GitHub Desktop.
func merge(cs ...<-chan int) <-chan int {
out := make(chan int)
var wg sync.WaitGroup
wg.Add(len(cs))
for _, c := range cs {
go func(c <-chan int) {
for v := range c {
out <- v
}
wg.Done()
}(c)
}
go func() {
wg.Wait()
close(out)
}()
return out
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment