keegancsmith/index.html

## index.html
<!DOCTYPE html>
<html lang="en">
  <head>
    <meta charset="UTF-8" />
    <meta http-equiv="X-UA-Compatible" content="IE=edge" />
    <meta name="viewport" content="width=device-width, initial-scale=1.0" />
    <title>SSE</title>
  </head>
  <body onload="onLoaded()">
    <h1>Server Sent Events</h1>
    <div id="main">
      <h3 id="rand-container">Random Number</h3>
      <div id="random-number"></div>
    </div>
    <script>
      const onLoaded = () => {
        let eventSource = new EventSource("/random");
        eventSource.onmessage = (event) => {
          document.getElementById("random-number").innerHTML = event.data;
        };
      };
    </script>
  </body>
</html>

## main.go
package main

import (
	"embed"
	_ "embed"
	"fmt"
	"log"
	"math/rand"
	"net/http"
	"time"

	"github.com/NYTimes/gziphandler"
	streamhttp "github.com/sourcegraph/sourcegraph/internal/search/streaming/http"
)

//go:embed index.html
var indexFS embed.FS

func main() {
	http.Handle("/", http.FileServer(http.FS(indexFS)))

	// default gzipMiddleware buffers small events
	//gzipMiddleware := gziphandler.GzipHandler
	gzipMiddleware, err := gziphandler.GzipHandlerWithOpts(gziphandler.MinSize(0))
	if err != nil {
		panic(err)
	}

	http.Handle("/random", gzipMiddleware(http.HandlerFunc(randomHandler)))

	log.Fatal(http.ListenAndServe(":8080", nil))
}

func randomHandler(w http.ResponseWriter, r *http.Request) {
	streamWriter, err := streamhttp.NewWriter(w)
	if err != nil {
		panic(err)
	}

	// send a random number every 2 seconds
	for {
		n := rand.Intn(100)
		log.Println(n)
		data := fmt.Sprintf("%d ", n)
		// uncomment below to force large event payloads. Without this default
		// gzip handler blocks.
		//data = strings.Repeat(data, 1000)
		err := streamWriter.Event("", data)
		if err != nil {
			return
		}
		time.Sleep(2 * time.Second)
	}
}
	<!DOCTYPE html>
	<html lang="en">
	<head>
	<meta charset="UTF-8" />
	<meta http-equiv="X-UA-Compatible" content="IE=edge" />
	<meta name="viewport" content="width=device-width, initial-scale=1.0" />
	<title>SSE</title>
	</head>
	<body onload="onLoaded()">
	<h1>Server Sent Events</h1>
	<div id="main">
	<h3 id="rand-container">Random Number</h3>
	<div id="random-number"></div>
	</div>
	<script>
	const onLoaded = () => {
	let eventSource = new EventSource("/random");
	eventSource.onmessage = (event) => {
	document.getElementById("random-number").innerHTML = event.data;
	};
	};
	</script>
	</body>
	</html>
	package main

	import (
	"embed"
	_ "embed"
	"fmt"
	"log"
	"math/rand"
	"net/http"
	"time"

	"github.com/NYTimes/gziphandler"
	streamhttp "github.com/sourcegraph/sourcegraph/internal/search/streaming/http"
	)

	//go:embed index.html
	var indexFS embed.FS

	func main() {
	http.Handle("/", http.FileServer(http.FS(indexFS)))

	// default gzipMiddleware buffers small events
	//gzipMiddleware := gziphandler.GzipHandler
	gzipMiddleware, err := gziphandler.GzipHandlerWithOpts(gziphandler.MinSize(0))
	if err != nil {
	panic(err)
	}

	http.Handle("/random", gzipMiddleware(http.HandlerFunc(randomHandler)))

	log.Fatal(http.ListenAndServe(":8080", nil))
	}

	func randomHandler(w http.ResponseWriter, r *http.Request) {
	streamWriter, err := streamhttp.NewWriter(w)
	if err != nil {
	panic(err)
	}

	// send a random number every 2 seconds
	for {
	n := rand.Intn(100)
	log.Println(n)
	data := fmt.Sprintf("%d ", n)
	// uncomment below to force large event payloads. Without this default
	// gzip handler blocks.
	//data = strings.Repeat(data, 1000)
	err := streamWriter.Event("", data)
	if err != nil {
	return
	}
	time.Sleep(2 * time.Second)
	}
	}