observer

type Observer interface {
	Subscribe(channel string) Subscriber
	Publish(channel string, msg interface{}) error
	Unsubscribe(channel string, subscriber Subscriber) error
	PubNumSub(channel string) map[string]int
}

type Subscriber interface {
	Channel() <-chan interface{}
	Close() error
}