trickle server

trickle.go

package main

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

func main() {
	log.SetFlags(log.Lshortfile)

	mux := http.NewServeMux()
	mux.HandleFunc("/", func(w http.ResponseWriter, r *http.Request) {
		log.Println("Request came in")
		timeout := time.After(10 * time.Second)
		for {
			select {
			case <-timeout:
				log.Println("Time up")
				return
			case <-r.Context().Done():
				log.Println("Client disconnected")
				return
			default:
			}

			log.Println("Stream some")
			w.Write([]byte("stream some"))
			if f, ok := w.(http.Flusher); ok {
				f.Flush()
			}
			time.Sleep(1 * time.Second)
		}
	})
	log.Println("Serving http://127.0.0.1:8080")
	if err := http.ListenAndServe("127.0.0.1:8080", mux); err != nil {
		log.Fatal(err)
	}
}