code: func (c *StreamConnection) Close() {
  	c.lock.Lock()
  	defer c.lock.Unlock()
  
  	if c.Closed() {
  		return
  	}
  
  	logger.Debug("Closing stream....")
  	if err := c.stream.CloseSend(); err != nil {
  		logger.Warnf("error closing GRPC stream: %s", err)
  	}
  
  	c.GRPCConnection.Close()
  }
docs: // Close closes the connection