events

Documentation

Index

• type TypedBus
  • func NewTypedBus[T any]() *TypedBus[T]
  • func (b *TypedBus[T]) Publish(v T)
  • func (b *TypedBus[T]) Subscribe(buffer int) <-chan T

Types

type TypedBus

type TypedBus[T any] struct {
	// contains filtered or unexported fields
}

TypedBus is a lightweight generic pub/sub bus for internal architecture events.

func NewTypedBus

func NewTypedBus[T any]() *TypedBus[T]

func (*TypedBus[T]) Publish

func (b *TypedBus[T]) Publish(v T)

func (*TypedBus[T]) Subscribe

func (b *TypedBus[T]) Subscribe(buffer int) <-chan T