sse

Nov 2, 2024

Changes in this version

+ func Parse(r io.Reader) <-chan *Message

+ type Message struct

+ Data *string

+ Event string

+ Id *string

+ func (m *Message) String() string

type Pusher

+ func NewPusher(w http.ResponseWriter) (Pusher, error)

+ type Receiver interface

+ Receive func(ctx context.Context) (*Message, error)

+ func NewReceiver(rc io.ReadCloser) Receiver

Oct 19, 2024

Changes in this version

+ func WriteEvent(w io.Writer, id int, event string, data any) error

Sep 17, 2024

Changes in this version

+ func CreatePusher(w http.ResponseWriter, argsFns ...OptionFunc) (*pusher, error)

+ func Receive(ctx context.Context, r io.ReadCloser) <-chan *Payload

+ type OptionFunc func(*pusherOptions)

+ func WithHeader(key, value string) OptionFunc

+ type Payload struct

+ Data json.RawMessage

+ Event string

+ Id int64

+ func (p *Payload) Decode(v any) error

+ type Pusher interface

+ Done func(ctx context.Context) error

+ Push func(ctx context.Context, id string, data any) error