Simple broadcast mechanism for multiple goroutines and a channel.

broadcaster.go

type Broadcaster[T any] struct {
	chans []chan T
}

func (b *Broadcaster[T]) Listen() chan T {
	c := make(chan T)
	b.chans = append(b.chans, c)
	return c
}

func (b *Broadcaster[T]) Send(i T) {
	for _, c := range b.chans {
		c <- i
	}
}

func (b *Broadcaster[T]) Close() {
	for _, c := range b.chans {
		close(c)
	}
}

// func main() {
//     var wg sync.WaitGroup
//     b := new(Broadcaster[int])
//     for i := 0; i < 10; i++ {
//         wg.Add(1)
//         go func(ch chan int) {
//             defer wg.Done()
//             v := <-ch
//             println(v)
//         }(b.Listen())
//     }
//     b.Send(100)
//     b.Close()
//     wg.Wait()
// }