gistfile1.go

var exitSelectCases []reflect.SelectCase

for i := 0; i < readersCount; i++ {
	r, err := nsq.NewReader(topic, channel)
	if err != nil {
		log.Fatalln("nsq.NewReader:", err)
	}
	r.SetMaxInFlight(2500)

	for j := 0; j < workersPerReader; j++ {
		r.AddHandler(w)
	}

	go func(rdr *nsq.Reader, lookupd []string) {
		for _, host := range lookupd {
			err := rdr.ConnectToLookupd(host)
			if err != nil {
				log.Fatalf("ConnectToLookupd @ %s: %s\n", host, err)
			}
		}
	}(r, hosts)

	fmt.Println("added reader", i)

	readers[i] = r
	exitSelectCases = append(exitSelectCases, reflect.SelectCase{Dir: SelectRecv, Chan: reflect.ValueOf(r.ExitChan)}) 
}

reflect.Select(exitSelectCases)