events

package

v1.53.0 Latest Latest Go to latest Published: Oct 19, 2026 License: Apache-2.0 Imports: 4 Imported by: 5

Details

View Source

const DefaultQueueSize = 16

This section is empty.

This section is empty.

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

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[V any] interface {
	Stop()
	Events() <-chan V
	// contains filtered or unexported methods
}

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

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

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(o *Options)

func WithBlocking() Option

func WithLogger(l logger.Logger) Option

func WithOptions(src Options) Option

func WithQueueSize(size int) Option

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

func DefaultOptions() Options