sse

Documentation

Index

• type Event
• type EventStream
  • func NewEventStreamFromReader(stream io.Reader, maxBufferSize int) *EventStream
  • func (e *EventStream) Next() (*Event, error)

Types

type Event

type Event struct {
	Data []byte
}

type EventStream

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

func NewEventStreamFromReader

func NewEventStreamFromReader(stream io.Reader, maxBufferSize int) *EventStream

NewEventStreamFromReader creates an instance of EventStream.

func (*EventStream) Next

func (e *EventStream) Next() (*Event, error)