newProducer_with_timeout.go

func newProducer(readTimeout time.Duration, products ...string) <-chan string {
	results := make(chan string)
	go func() {
		defer close(results)
		for _, product := range products {
			select {
			case results <- product:
				// didn't time out
			case <-time.After(readTimeout):
				return
			}
		}
	}()
	return results
}