stream

package

v0.1.22 Latest Latest Go to latest Published: Feb 27, 2026 License: MIT Imports: 9 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

BaseStreamReader provides generic SSE stream reading capabilities

func NewBaseStreamReader[T any](ctx context.Context, resp *http.Response, parser SSEParser[T]) *BaseStreamReader[T]

NewBaseStreamReader creates a new base stream reader

func (r *BaseStreamReader[T]) Close() error

Close closes the stream reader and releases resources

func (r *BaseStreamReader[T]) Recv() (T, error)

Recv receives the next item from the stream

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

SSEDecoder decodes Server-Sent Events from an io.Reader

func NewSSEDecoder(reader io.Reader) *SSEDecoder

NewSSEDecoder creates a new SSE decoder

func (d *SSEDecoder) Decode(ctx context.Context) <-chan SSEEvent

Decode decodes SSE events from the reader and returns a channel

func (d *SSEDecoder) DecodeEvent() (*ServerSentEvent, error)

DecodeEvent decodes a single SSE event

type SSEEvent struct {
	Event *ServerSentEvent
	Error error
}

SSEEvent wraps either an event or an error

type SSEParser[T any] interface {
	Parse(sse *ServerSentEvent) (T, error)
	HandleError(sse *ServerSentEvent) error
}

SSEParser defines the interface for parsing SSE events into specific types

type ServerSentEvent struct {
	Event string
	Data  string
	ID    string
	Retry *int
}

ServerSentEvent represents a Server-Sent Event

func (sse *ServerSentEvent) JSON(v interface{}) error

JSON unmarshals the Data field into the provided interface