code: func (c *Client) Connect() {
  	for c.GetState() == DisconnectedState {
  		go c.resubscribe()
  		c.doConnection()
  		time.Sleep(c.policy.Next())
  	}
  
  	c.setState(ClosedState)
  }
docs: // Tries to reconnect to pubsub, looping until we're able to do so
  // successfully. This must be called to activate the client.