in client/Apache.ShenYu.Client/Utils/Zookeeper/ZookeeperClient.cs [334:354]
private async Task OnConnectionStateChange(WatchedEvent watchedEvent)
{
if (_isDispose)
return;
var state = watchedEvent.getState();
SetCurrentState(state);
if (state == Event.KeeperState.Expired)
{
await ReConnect();
}
_stateChangedCondition.Set();
if (_connectionStateChangeHandler == null)
return;
await _connectionStateChangeHandler(this, new ConnectionStateChangeArgs
{
State = state
});
}