Method Run

examples/streaming/stdhttp/sse/impl.go:28–45

(ctx context.Context)

	return s
}
func (s Server) Run(ctx context.Context) error {
	go func() {
		<-ctx.Done()
		slog.Warn("context cancelled, shutting down")
		ctxTimeout, cancel := context.WithTimeout(context.Background(), 5*time.Second)
		err := s.httpServer.Shutdown(ctxTimeout)
		cancel()
		if err != nil {
			slog.Error("httpServer.Shutdown() error", "error", err)
		}
	}()

	err := s.httpServer.ListenAndServe()
	if err != nil && !errors.Is(err, http.ErrServerClosed) {
		return fmt.Errorf("httpServer.ListenAndServe() error: %w", err)
	}
	return nil
}

type SObject struct {
	Time     time.Time `json:"time"`