250_state = new ReconnectingConnectionState(_logger);

198public string? ConnectionId => _state.CurrentConnectionStateUnsynchronized?.Connection.ConnectionId; 203public HubConnectionState State => _state.OverallState; 283await _state.WaitConnectionLockAsync(token: cancellationToken).ConfigureAwait(false); 286if (!_state.TryChangeState(HubConnectionState.Disconnected, HubConnectionState.Connecting)) 293if (_state.StopCts.Token.IsCancellationRequested) 298using (CancellationTokenUtils.CreateLinkedToken(cancellationToken, _state.StopCts.Token, out var linkedToken)) 303_state.ChangeState(HubConnectionState.Connecting, HubConnectionState.Connected); 307if (_state.TryChangeState(HubConnectionState.Connecting, HubConnectionState.Disconnected)) 309_state.StopCts = new CancellationTokenSource(); 316_state.ReleaseConnectionLock(); 493_state.AssertInConnectionLock(); 494SafeAssert(_state.CurrentConnectionStateUnsynchronized == null, "We already have a connection!"); 548_state.CurrentConnectionStateUnsynchronized = startingConnectionState; 580var connectionState = _state.CurrentConnectionStateUnsynchronized; 718_state.StopCts.Cancel(); 722await _state.WaitConnectionLockAsync(token: default).ConfigureAwait(false); 725var reconnectTask = _state.ReconnectTask; 733_state.ReleaseConnectionLock(); 735await _state.WaitConnectionLockAsync(token: default).ConfigureAwait(false); 751connectionState = _state.CurrentConnectionStateUnsynchronized; 782_state.StopCts = new CancellationTokenSource(); 808_state.ReleaseConnectionLock(); 887_state.ReleaseConnectionLock(); 958_state.AssertInConnectionLock(); 1124await _state.WaitConnectionLockAsync(token: default).ConfigureAwait(false); 1128if (_state.IsConnectionActive()) 1144_state.ReleaseConnectionLock(); 1157var connectionStateTask = _state.WaitForActiveConnectionAsync(sendingMethodName, token); 1238_state.ReleaseConnectionLock(); 1281await _state.WaitConnectionLockAsync(token: default).ConfigureAwait(false); 1284if (_state.CurrentConnectionStateUnsynchronized != null) 1289await SendHubMessage(_state.CurrentConnectionStateUnsynchronized, new CancelInvocationMessage(irq.InvocationId), cancellationToken: default).ConfigureAwait(false); 1302_state.ReleaseConnectionLock(); 1340_state.AssertConnectionValid(); 1383_state.AssertConnectionValid(); 1439_state.ReleaseConnectionLock(); 1446var connectionState = await _state.WaitForActiveConnectionAsync(callerName, token: cancellationToken).ConfigureAwait(false); 1457_state.ReleaseConnectionLock(); 1774_state.AssertInConnectionLock(); 1897return _state.CurrentConnectionStateUnsynchronized!.RunTimerActions(); 1904_state.CurrentConnectionStateUnsynchronized!.OnServerTimeout(); 1910await _state.WaitConnectionLockAsync(token: default).ConfigureAwait(false); 1913SafeAssert(ReferenceEquals(_state.CurrentConnectionStateUnsynchronized, connectionState), 1915_state.CurrentConnectionStateUnsynchronized = null; 1935_state.ChangeState(HubConnectionState.Connected, HubConnectionState.Disconnected); 1940_state.ReconnectTask = ReconnectAsync(connectionState.CloseException); 1945_state.ReleaseConnectionLock(); 1951_state.AssertInConnectionLock(); 1952_state.StopCts = new CancellationTokenSource(); 1992_state.AssertInConnectionLock(); 1998_state.ChangeState(HubConnectionState.Connected, HubConnectionState.Disconnected); 2004_state.ChangeState(HubConnectionState.Connected, HubConnectionState.Reconnecting); 2023await Task.Delay(nextRetryDelay.Value, _state.StopCts.Token).ConfigureAwait(false); 2029await _state.WaitConnectionLockAsync(token: default).ConfigureAwait(false); 2032_state.ChangeState(HubConnectionState.Reconnecting, HubConnectionState.Disconnected); 2034CompleteClose(GetOperationCanceledException("Connection stopped during reconnect delay. Done reconnecting.", ex, _state.StopCts.Token)); 2038_state.ReleaseConnectionLock(); 2044await _state.WaitConnectionLockAsync(token: default).ConfigureAwait(false); 2047SafeAssert(ReferenceEquals(_state.CurrentConnectionStateUnsynchronized, null), 2050await StartAsyncCore(_state.StopCts.Token).ConfigureAwait(false); 2054_state.ChangeState(HubConnectionState.Reconnecting, HubConnectionState.Connected); 2065if (_state.StopCts.IsCancellationRequested) 2069_state.ChangeState(HubConnectionState.Reconnecting, HubConnectionState.Disconnected); 2071CompleteClose(GetOperationCanceledException("Connection stopped during reconnect attempt. Done reconnecting.", ex, _state.StopCts.Token)); 2079_state.ReleaseConnectionLock(); 2085await _state.WaitConnectionLockAsync(token: default).ConfigureAwait(false); 2088SafeAssert(ReferenceEquals(_state.CurrentConnectionStateUnsynchronized, null), 2094_state.ChangeState(HubConnectionState.Reconnecting, HubConnectionState.Disconnected); 2101_state.ReleaseConnectionLock(); 2128return new OperationCanceledException(message, innerException, _state.StopCts.Token); 2435_hubConnection._state.AssertInConnectionLock(); 2479var connectionToken = _hubConnection._state.StopCts.Token; 2546if (!_hubConnection._state.TryAcquireConnectionLock()) 2556if (_hubConnection._state.CurrentConnectionStateUnsynchronized != null) 2558SafeAssert(ReferenceEquals(_hubConnection._state.CurrentConnectionStateUnsynchronized, this), 2570_hubConnection._state.ReleaseConnectionLock();