ssestream

package

v1.11.0 Latest Latest Go to latest Published: Jul 16, 2025 License: Apache-2.0 Imports: 8 Imported by: 32

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 (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 {
		...
 	}