code: func NewEmitter() *Emitter {
  	pubsubServer := pubsub.NewServer(pubsub.BufferCapacity(DefaultEventBufferCapacity))
  	pubsubServer.BaseService = *common.NewBaseService(nil, "Emitter", pubsubServer)
  	pubsubServer.Start()
  	return &Emitter{
  		pubsubServer: pubsubServer,
  	}
  }
docs: // NewEmitter initializes an emitter struct with a pubsubServer