23 lines
646 B
C#
23 lines
646 B
C#
using System.Collections.Concurrent;
|
|
using Microsoft.AspNetCore.SignalR;
|
|
|
|
namespace RdtClient.Service.Services;
|
|
|
|
public class RdtHub : Hub
|
|
{
|
|
private static readonly ConcurrentDictionary<String, String> Users = new();
|
|
|
|
public static Boolean HasConnections => !Users.IsEmpty;
|
|
|
|
public override async Task OnConnectedAsync()
|
|
{
|
|
Users.TryAdd(Context.ConnectionId, Context.ConnectionId);
|
|
await base.OnConnectedAsync();
|
|
}
|
|
|
|
public override async Task OnDisconnectedAsync(Exception? exception)
|
|
{
|
|
Users.TryRemove(Context.ConnectionId, out _);
|
|
await base.OnDisconnectedAsync(exception);
|
|
}
|
|
}
|