From 175623993237a90c2f0739326609fb272cbd62aa Mon Sep 17 00:00:00 2001
From: Stanley Dimant <root.darkarchon@outlook.com>
Date: Thu, 7 Nov 2024 01:00:47 +0100
Subject: [PATCH] it's concurrentdict time

---
 MareSynchronos/Services/Mediator/MareMediator.cs | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/MareSynchronos/Services/Mediator/MareMediator.cs b/MareSynchronos/Services/Mediator/MareMediator.cs
index 622e2c4..eecdb4c 100644
--- a/MareSynchronos/Services/Mediator/MareMediator.cs
+++ b/MareSynchronos/Services/Mediator/MareMediator.cs
@@ -10,15 +10,15 @@ namespace MareSynchronos.Services.Mediator;
 public sealed class MareMediator : IHostedService
 {
     private readonly object _addRemoveLock = new();
-    private readonly Dictionary<object, DateTime> _lastErrorTime = [];
+    private readonly ConcurrentDictionary<object, DateTime> _lastErrorTime = [];
     private readonly ILogger<MareMediator> _logger;
     private readonly CancellationTokenSource _loopCts = new();
     private readonly ConcurrentQueue<MessageBase> _messageQueue = new();
     private readonly PerformanceCollectorService _performanceCollector;
     private readonly MareConfigService _mareConfigService;
-    private readonly Dictionary<Type, HashSet<SubscriberAction>> _subscriberDict = [];
+    private readonly ConcurrentDictionary<Type, HashSet<SubscriberAction>> _subscriberDict = [];
     private bool _processQueue = false;
-    private readonly Dictionary<Type, MethodInfo?> _genericExecuteMethods = new();
+    private readonly ConcurrentDictionary<Type, MethodInfo?> _genericExecuteMethods = new();
     public MareMediator(ILogger<MareMediator> logger, PerformanceCollectorService performanceCollector, MareConfigService mareConfigService)
     {
         _logger = logger;