event

Mar 2, 2022

Changes in this version

+ const DATA

+ const END

+ const START

+ func Listen(s Stream, job Job)

+ func ListenWithContext(s Stream, ctx context.Context, job Job)

+ func NewProvider(capacity int, ctx context.Context) *provider

+ func NewProviderWithStream(capacity int, s Stream, ctx context.Context) *provider

+ func NewStream() *stream

+ type Event struct

+ Data interface{}

+ Error string

+ Type byte

+ func NewEndEvent() Event

+ func NewEvent(t byte, data interface{}, err error) Event

+ func NewStartEvent() Event

+ type Job func(ctx context.Context, notify Notify)

+ type Notifier interface

+ Notify func(data interface{})

+ type Notify func(data interface{})

+ func (fn Notify) Notify(data interface{})

+ type Provider interface

+ Cancel func(id string)

+ CancelAll func()

+ Close func()

+ Start func()

+ Sub func(s Stream) (id string)

+ type Stream interface

+ OnData func(b []byte)