From b67c30a2c767d07aedc057d7dfb3bf1094ec13f1 Mon Sep 17 00:00:00 2001 From: ngfrolov Date: Mon, 22 Jan 2024 12:55:48 +0500 Subject: [PATCH] fix PeriodicBackgroundWorker.Add() --- AsbCloudInfrastructure/Background/PeriodicBackgroundWorker.cs | 3 +-- .../Background/PeriodicBackgroundWorkerTest.cs | 3 +-- 2 files changed, 2 insertions(+), 4 deletions(-) diff --git a/AsbCloudInfrastructure/Background/PeriodicBackgroundWorker.cs b/AsbCloudInfrastructure/Background/PeriodicBackgroundWorker.cs index 0a7e96dd..fbbfd58e 100644 --- a/AsbCloudInfrastructure/Background/PeriodicBackgroundWorker.cs +++ b/AsbCloudInfrastructure/Background/PeriodicBackgroundWorker.cs @@ -89,8 +89,7 @@ public class PeriodicBackgroundWorker : BackgroundService where T : Work, new() { var work = new T(); - var periodic = new WorkPeriodic(work, period); - works.Add(periodic); + Add(work, period); } /// diff --git a/AsbCloudWebApi.Tests/Background/PeriodicBackgroundWorkerTest.cs b/AsbCloudWebApi.Tests/Background/PeriodicBackgroundWorkerTest.cs index 938d8106..69f3d488 100644 --- a/AsbCloudWebApi.Tests/Background/PeriodicBackgroundWorkerTest.cs +++ b/AsbCloudWebApi.Tests/Background/PeriodicBackgroundWorkerTest.cs @@ -55,14 +55,13 @@ public class PeriodicBackgroundWorkerTest var stopwatch = Stopwatch.StartNew(); service.Add(work, period); - var delay = periodMs / 20 + periodMs * workCount - stopwatch.ElapsedMilliseconds; + var delay = (periodMs / 20) + (periodMs * workCount) - stopwatch.ElapsedMilliseconds; await Task.Delay(TimeSpan.FromMilliseconds(delay)); //assert Assert.Equal(workCount, result); } - [Fact] public async Task Enqueue_Continues_AfterExceptions() {