code: func (ref *EventClientRef) Close() {
  	if !atomic.CompareAndSwapInt32(&ref.closed, 0, 1) {
  		// Already closed
  		return
  	}
  
  	logger.Debug("Closing the event client")
  	ref.ref.Close()
  }
docs: // Close immediately closes the connection.