eriknelson · September 29, 2017 00:40
diff --git a/aggregator_channel.go b/aggregator_channel.go
 agg := make(chan string)
 for _, ch := range chans {
  go func(c chan string) {
    for msg := range c {
      agg <- msg
    }
  }(ch)
 }

 select {
 case msg <- agg:
    fmt.Println("received ", msg)
 }
	agg := make(chan string)
	for _, ch := range chans {
	go func(c chan string) {
	for msg := range c {
	agg <- msg
	}
	}(ch)
	}

	select {
	case msg <- agg:
	fmt.Println("received ", msg)
	}