ssestream

package

v0.0.0-...-d0740cc Latest Latest Go to latest Published: Mar 19, 2026 License: Apache-2.0 Imports: 9 Imported by: 1

Details

This section is empty.

This section is empty.

func RegisterDecoder(contentType string, decoder func(io.ReadCloser) Decoder)

type Decoder interface {
	Event() Event
	Next() bool
	Close() error
	Err() error
}

func NewDecoder(res *http.Response) Decoder

type Event struct {
	Type string
	Data []byte
}

type Stream[T any] struct {
	// contains filtered or unexported fields
}

func NewStream[T any](decoder Decoder, err error) *Stream[T]

func NewStreamWithSynthesizeEventData[T any](decoder Decoder, err error) *Stream[T]

func (s *Stream[T]) Close() error

func (s *Stream[T]) Current() T

func (s *Stream[T]) Err() error

func (s *Stream[T]) Next() bool

Next returns false if the stream has ended or an error occurred. Call Stream.Current() to get the current value. Call Stream.Err() to get the error.

	for stream.Next() {
		data := stream.Current()
	}

 	if stream.Err() != nil {
		...
 	}

type StreamError struct {
	Message string
	Event   Event
}

StreamError represents an error event that occurred during streaming, preserving the original event data for structured access.

func (e *StreamError) Error() string