}
c.subscriptionLock.Lock()
defer c.subscriptionLock.Unlock()
if notifyingClient, ok := c.client.(NotifyingClient); ok {
c.cancelClientSubscription = notifyingClient.Subscribe(c.keysChanged)
c.poller.Go(c.pollForChanges)
}