event

Documentation

Index

• Constants
• 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
  • func NewEndEvent() Event
  • func NewEvent(t byte, data interface{}, err error) Event
  • func NewStartEvent() Event
• type Job
• type Notifier
• type Notify
  • func (fn Notify) Notify(data interface{})
• type Provider
• type Stream

Constants

const (
	DATA  byte = 0
	START byte = 1
	END   byte = 2
)

Functions

func Listen

func Listen(s Stream, job Job)

func ListenWithContext

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

func NewProvider

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

func NewProviderWithStream

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

func NewStream

func NewStream() *stream

Types

type Event

type Event struct {
	Type  byte
	Error string
	Data  interface{}
}

func NewEndEvent

func NewEndEvent() Event

func NewEvent

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

func NewStartEvent

func NewStartEvent() Event

type Job

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

type Notifier

type Notifier interface {
	Notify(data interface{})
}

type Notify

type Notify func(data interface{})

func (Notify) Notify

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

type Provider

type Provider interface {
	Notifier
	xnet.IDCode
	Start()
	Close()
	Sub(s Stream) (id string)
	Cancel(id string)
	CancelAll()
}

type Stream

type Stream interface {
	OnData(b []byte)
}