diff --git a/DysonNetwork.Pass/Handlers/LastActiveFlushHandler.cs b/DysonNetwork.Pass/Handlers/LastActiveFlushHandler.cs index d45dd1f..b9b95aa 100644 --- a/DysonNetwork.Pass/Handlers/LastActiveFlushHandler.cs +++ b/DysonNetwork.Pass/Handlers/LastActiveFlushHandler.cs @@ -53,7 +53,7 @@ public class LastActiveFlushHandler(IServiceProvider srp, ILogger logger) : IJob +public class LastActiveFlushJob(FlushBufferService fbs, LastActiveFlushHandler hdl, ILogger logger) : IJob { public async Task Execute(IJobExecutionContext context) { diff --git a/DysonNetwork.Shared/Cache/FlushBufferService.cs b/DysonNetwork.Shared/Cache/FlushBufferService.cs index 4a6adbb..bc883ec 100644 --- a/DysonNetwork.Shared/Cache/FlushBufferService.cs +++ b/DysonNetwork.Shared/Cache/FlushBufferService.cs @@ -18,11 +18,9 @@ public class FlushBufferService(ILogger logger) var type = typeof(T); lock (_lockObject) { - if (!_buffers.TryGetValue(type, out var buffer)) - { - buffer = new ConcurrentQueue(); - _buffers[type] = buffer; - } + if (_buffers.TryGetValue(type, out var buffer)) return (ConcurrentQueue)buffer; + buffer = new ConcurrentQueue(); + _buffers[type] = buffer; return (ConcurrentQueue)buffer; } }