sse

package

v0.3.0 Latest Latest Go to latest Published: Oct 30, 2026 License: Apache-2.0 Imports: 4 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Stream struct {
	// contains filtered or unexported fields
}

Stream writes SSE frames and bounds each client write.

func New(w http.ResponseWriter) *Stream

New constructs a Stream for w.

func (s *Stream) BeginWrite() error

BeginWrite starts a bounded write sequence. Call Flush after its frames.

func (s *Stream) ClearWriteDeadline() error

ClearWriteDeadline ends a write sequence that failed before Flush.

func (s *Stream) Data(data []byte) error

Data writes and flushes an SSE data frame.

func (s *Stream) Flush() error

Flush delivers pending frames and clears their write deadline.

func (s *Stream) KeepAlive() error

KeepAlive writes and flushes an SSE comment heartbeat.

func (s *Stream) Writef(format string, args ...any) error

Writef writes an SSE frame. Call Flush to deliver buffered frames.