code: func (bus *EventBus) Subscribe(topic string, fn interface{}) error {
  	return bus.doSubscribe(topic, fn, &eventHandler{
  		reflect.ValueOf(fn), false, false, false, sync.Mutex{},
  	})
  }
docs: // Subscribe subscribes to a topic.
  // Returns error if `fn` is not a function.