1 instantiation of ConnectionState
Microsoft.AspNetCore.SignalR.Client.Core (1)
32 references to ConnectionState
Microsoft.AspNetCore.SignalR.Client.Core (32)
HubConnection.cs (32)
97private ConnectionState? _authRefreshConnectionState;
526var startingConnectionState = new ConnectionState(connection, this);
605var connectionState = _state.CurrentConnectionStateUnsynchronized;
614private async Task<TimeSpan?> RefreshAuthenticationAsyncCore(ConnectionState connectionState, CancellationToken cancellationToken)
696private void ScheduleAuthenticationRefresh(TimeSpan tokenLifetime, ConnectionState connectionState)
727private void ScheduleAuthenticationRefreshAt(TimeSpan refreshIn, ConnectionState connectionState)
801private void EnableAuthenticationRefreshTimer(ConnectionState connectionState)
829private sealed class AuthenticationRefreshTimerState(HubConnection hubConnection, ConnectionState connectionState)
833public ConnectionState ConnectionState { get; } = connectionState;
871ConnectionState? connectionState;
1027private Dictionary<string, object>? PackageStreamingParams(ConnectionState connectionState, ref object?[] args, out List<string>? streamIds)
1084private Task[]? LaunchStreams(ConnectionState connectionState, Dictionary<string, object>? readers, CancellationToken cancellationToken)
1140private Task InvokeStreamMethod(MethodInfo methodInfo, Type[] genericTypes, ConnectionState connectionState, string streamId, object reader, CancellationTokenSource tokenSource)
1162private Task ReflectionSendStreamItems(MethodInfo methodInfo, ConnectionState connectionState, string streamId, object reader, CancellationTokenSource tokenSource)
1198private Task SendStreamItems<T>(ConnectionState connectionState, string streamId, ChannelReader<T> reader, CancellationTokenSource tokenSource)
1215private Task SendIAsyncEnumerableStreamItems<T>(ConnectionState connectionState, string streamId, IAsyncEnumerable<T> stream, CancellationTokenSource tokenSource)
1228private async Task SendStreamItemAsync(ConnectionState connectionState, string streamId, object? item, CancellationTokenSource tokenSource)
1234private async Task CommonStreaming(ConnectionState connectionState, string streamId, Func<Task> createAndConsumeStream, CancellationTokenSource cts)
1282private async Task<(ConnectionState, Activity?)> WaitForActiveConnectionWithActivityAsync(string sendingMethodName, string invokedMethodName, CancellationToken token)
1290ConnectionState connectionState;
1443private async Task InvokeCore(ConnectionState connectionState, string methodName, InvocationRequest irq, object?[] args, string[]? streams, CancellationToken cancellationToken)
1472private async Task InvokeStreamCore(ConnectionState connectionState, string methodName, InvocationRequest irq, object?[] args, string[]? streams, CancellationToken cancellationToken)
1515private async Task SendHubMessage(ConnectionState connectionState, HubMessage hubMessage, CancellationToken cancellationToken = default)
1577private async Task SendWithLock(ConnectionState expectedConnectionState, HubMessage message, CancellationToken cancellationToken, [CallerMemberName] string callerName = "")
1580var connectionState = await _state.WaitForActiveConnectionAsync(callerName, token: cancellationToken).ConfigureAwait(false);
1595private async Task<CloseMessage?> ProcessMessagesAsync(HubMessage message, ConnectionState connectionState, ChannelWriter<InvocationMessage> invocationMessageWriter)
1682private async Task DispatchInvocationAsync(InvocationMessage invocation, ConnectionState connectionState)
1799private async Task HandshakeAsync(ConnectionState startingConnectionState, int protocolVersion, CancellationToken cancellationToken)
1904private async Task ReceiveLoop(ConnectionState connectionState)
2041private async Task HandleConnectionClose(ConnectionState connectionState)
2752public ConnectionState? CurrentConnectionStateUnsynchronized { get; set; }
2810public async Task<ConnectionState> WaitForActiveConnectionAsync(string methodName, CancellationToken token)