code: func (up *UnbufferedPublisher) Close() error {
  	client, err := up.ClientFactory.Client(up.AECtx)
  	if err != nil {
  		return err
  	}
  	return client.Close()
  }
docs: // Close closes the UnbufferedPublisher, notably its Client.