Function flush

intercept/eventstream/eventstream.go:235–248

(w http.ResponseWriter)

}

func flush(w http.ResponseWriter) (err error) {
	flusher, ok := w.(http.Flusher)
	if !ok || flusher == nil {
		return xerrors.New("SSE not supported")
	}

	defer func() {
		if r := recover(); r != nil { //nolint:revive,staticcheck // Intentionally swallowed; likely a broken connection.
		}
	}()

	flusher.Flush()
	return nil
}