pubsub

Feb 16, 2024

Changes in this version

+ type Topic struct

+ func New[T any]() *Topic[T]

+ func (s *Topic[T]) Close() error

+ func (s *Topic[T]) Publish(t T)

+ func (s *Topic[T]) Subscribe(c chan T) chan T

+ func (s *Topic[T]) Unsubscribe(c chan T)