Простой броадкастер на Go

bcast.go

package bcast

type Broadcaster interface {
	// Неблокирующая отправка сообщения
	Send(interface{})
	// Блокирующее получение одного сообщения
	Fetch() interface{}
}

type bcaster struct {
	in        chan interface{}
	listeners chan chan interface{}
}

func NewBroadcaster() Broadcaster {
	b := &bcaster{
		in:        make(chan interface{}),
		listeners: make(chan chan interface{}),
	}
	go b.run()
	return b
}

func (b *bcaster) Send(v interface{}) {
	go func() { b.in <- v }()
}

func (b *bcaster) Fetch() interface{} {
	ch := make(chan interface{})
	b.listeners <- ch
	v := <-ch
	close(ch)
	return v
}

func (b *bcaster) run() {
	for {
		v := <-b.in
	loop:
		for {
			select {
			case ch := <-b.listeners:
				go func() { ch <- v }()
			default:
				break loop
			}
		}
	}
}