1 instantiation of AckInfo
Microsoft.AspNetCore.SignalR.StackExchangeRedis (1)
Internal\AckHandler.cs (1)
32return _acks.GetOrAdd(id, _ => new AckInfo()).Tcs.Task;
5 references to AckInfo
Microsoft.AspNetCore.SignalR.StackExchangeRedis (5)
Internal\AckHandler.cs (5)
11private readonly ConcurrentDictionary<int, AckInfo> _acks = new ConcurrentDictionary<int, AckInfo>(); 38if (_acks.TryRemove(id, out var ack)) 58if (_acks.TryRemove(pair.Key, out var ack)) 76if (_acks.TryRemove(pair.Key, out var ack))