code: func (p *Publisher) SubscribeTopic(topic topicFunc) chan interface{} {
  	ch := make(chan interface{}, p.buffer)
  	p.m.Lock()
  	p.subscribers[ch] = topic
  	p.m.Unlock()
  	return ch
  }
docs: // SubscribeTopic adds a new subscriber that filters messages sent by a topic.