triggers

Documentation

Index

• type StreamTriggers
  • func New[T comparable]() *StreamTriggers[T]
  • func (t *StreamTriggers[T]) Add(id T) (<-chan struct{}, error)
  • func (t *StreamTriggers[T]) Close()
  • func (t *StreamTriggers[T]) Exists(id T) bool
  • func (t *StreamTriggers[T]) Keys() []T
  • func (t *StreamTriggers[T]) Length() int
  • func (t *StreamTriggers[T]) Remove(id T)
  • func (t *StreamTriggers[T]) Trigger(id T)
  • func (t *StreamTriggers[T]) TriggerAll()

Types

type StreamTriggers

type StreamTriggers[T comparable] struct {
	// contains filtered or unexported fields
}

func New

func New[T comparable]() *StreamTriggers[T]

func (*StreamTriggers[T]) Add

func (t *StreamTriggers[T]) Add(id T) (<-chan struct{}, error)

func (*StreamTriggers[T]) Close

func (t *StreamTriggers[T]) Close()

func (*StreamTriggers[T]) Exists

func (t *StreamTriggers[T]) Exists(id T) bool

func (*StreamTriggers[T]) Keys

func (t *StreamTriggers[T]) Keys() []T

func (*StreamTriggers[T]) Length

func (t *StreamTriggers[T]) Length() int

func (*StreamTriggers[T]) Remove

func (t *StreamTriggers[T]) Remove(id T)

func (*StreamTriggers[T]) Trigger

func (t *StreamTriggers[T]) Trigger(id T)

func (*StreamTriggers[T]) TriggerAll

func (t *StreamTriggers[T]) TriggerAll()