events

Documentation

Index

• Constants
• type Emitter
  • func NewEmitter[K comparable, V any](opts ...Option) *Emitter[K, V]
  • func (e *Emitter[K, V]) Emit(k K, v V)
  • func (e *Emitter[K, V]) Notify(k K, ch chan V) func()
  • func (e *Emitter[K, V]) Observe(k K) Observer[V]
  • func (e *Emitter[K, V]) ObservedKeys() []K
  • func (e *Emitter[K, V]) On(k K, f func(V)) func()
• type Observer
  • func NewObserver[V any](stopFunc func()) (Observer[V], func(v V))
• type ObserverList
  • func NewObserverList[V any](opts ...Option) *ObserverList[V]
  • func (l *ObserverList[V]) Emit(v V)
  • func (l *ObserverList[V]) Len() int
  • func (l *ObserverList[V]) Notify(ch chan V) func()
  • func (l *ObserverList[V]) Observe() Observer[V]
  • func (l *ObserverList[V]) On(f func(V)) func()
• type Option
  • func WithBlocking() Option
  • func WithLogger(l logger.Logger) Option
  • func WithOptions(src Options) Option
  • func WithQueueSize(size int) Option
• type Options
  • func DefaultOptions() Options

Constants

const DefaultQueueSize = 16

Types

type Emitter

type Emitter[K comparable, V any] struct {
	// contains filtered or unexported fields
}

func NewEmitter

func NewEmitter[K comparable, V any](opts ...Option) *Emitter[K, V]

func (*Emitter[K, V]) Emit

func (e *Emitter[K, V]) Emit(k K, v V)

func (*Emitter[K, V]) Notify

func (e *Emitter[K, V]) Notify(k K, ch chan V) func()

func (*Emitter[K, V]) Observe

func (e *Emitter[K, V]) Observe(k K) Observer[V]

func (*Emitter[K, V]) ObservedKeys

func (e *Emitter[K, V]) ObservedKeys() []K

func (*Emitter[K, V]) On

func (e *Emitter[K, V]) On(k K, f func(V)) func()

type Observer

type Observer[V any] interface {
	Stop()
	Events() <-chan V
	// contains filtered or unexported methods
}

func NewObserver

func NewObserver[V any](stopFunc func()) (Observer[V], func(v V))

type ObserverList

type ObserverList[V any] struct {
	// contains filtered or unexported fields
}

func NewObserverList

func NewObserverList[V any](opts ...Option) *ObserverList[V]

func (*ObserverList[V]) Emit

func (l *ObserverList[V]) Emit(v V)

func (*ObserverList[V]) Len

func (l *ObserverList[V]) Len() int

func (*ObserverList[V]) Notify

func (l *ObserverList[V]) Notify(ch chan V) func()

func (*ObserverList[V]) Observe

func (l *ObserverList[V]) Observe() Observer[V]

func (*ObserverList[V]) On

func (l *ObserverList[V]) On(f func(V)) func()

type Option

type Option func(o *Options)

func WithBlocking

func WithBlocking() Option

func WithLogger

func WithLogger(l logger.Logger) Option

func WithOptions

func WithOptions(src Options) Option

func WithQueueSize

func WithQueueSize(size int) Option

type Options

type Options struct {
	QueueSize int
	Blocking  bool
	Logger    logger.Logger
}

func DefaultOptions

func DefaultOptions() Options