callbacks

Documentation

Index

• type Callback
  • func New[V any]() *Callback[V]
  • func (p *Callback[V]) AddMessage(msg V)
  • func (p *Callback[V]) Subscribe(name string, fn func(msg V) bool)
  • func (p *Callback[V]) Unsubscribe(name string) bool

Types

type Callback

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

func New

func New[V any]() *Callback[V]

func (*Callback[V]) AddMessage

func (p *Callback[V]) AddMessage(msg V)

func (*Callback[V]) Subscribe

func (p *Callback[V]) Subscribe(name string, fn func(msg V) bool)

func (*Callback[V]) Unsubscribe

func (p *Callback[V]) Unsubscribe(name string) bool