simple_web_app.go

package main

import (
	"fmt"
	"log"
	"net/http"
)

func newProducer(products ...string) <-chan string {
	results := make(chan string)
	go func() {
		defer close(results)
		for _, product := range products {
			results <- product
		}
	}()
	return results
}

func exampleEndpoint(w http.ResponseWriter, req *http.Request) {
	var counter = 0
	for result := range newProducer("A", "B", "C", "E", "F", "G") {
		counter++
		fmt.Fprintln(w, result)
		if counter == 3 {
			return
		}
	}
}

func main() {
	http.HandleFunc("/example", exampleEndpoint)
	log.Fatal(http.ListenAndServe(":8080", nil))
}