pubsub

Documentation

Index

• Variables
• type Bus
  • func NewBus[T any]() Bus[T]

Variables

var ErrNotRunning = errors.New("not running")

ErrNotRunning is the error with message "not running"

Types

type Bus

type Bus[T any] interface {
	Publish(T) error
	Subscribe(filter func(T) bool) <-chan T
	Close()
	Done() <-chan struct{}
}

Bus provides a general purpose interface for message passing

func NewBus

func NewBus[T any]() Bus[T]

NewBus runs a new bus and returns bus details