Skip to content

Commit fd5155b

Browse files
committed
fix incorrect disposals (finally)
1 parent b6f6495 commit fd5155b

2 files changed

Lines changed: 3 additions & 12 deletions

File tree

DragonFruit.Data.Queues/Jobs/Job.cs

Lines changed: 0 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,6 @@
33

44
using System;
55
using System.Threading.Tasks;
6-
using Microsoft.Extensions.DependencyInjection;
76

87
namespace DragonFruit.Data.Queues.Jobs
98
{
@@ -18,13 +17,5 @@ public abstract class Job
1817
/// Performs the current job as an asynchronous task
1918
/// </summary>
2019
public abstract Task Perform(IServiceProvider scope);
21-
22-
internal async Task PerformInternal(IServiceScope scope)
23-
{
24-
using (scope)
25-
{
26-
await Perform(scope.ServiceProvider).ConfigureAwait(false);
27-
}
28-
}
2920
}
3021
}

DragonFruit.Data.Queues/QueueProcessor.cs

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -198,16 +198,16 @@ protected override async Task ExecuteAsync(CancellationToken cancellation)
198198

199199
if (ScopeLifetime == ScopeOptions.PerCycle)
200200
{
201-
jobTasks.Add(job.PerformInternal(jobCycleScope.Value));
201+
jobTasks.Add(job.Perform(jobCycleScope.Value.ServiceProvider));
202202
}
203203
else if (batchScope != null)
204204
{
205-
jobTasks.Add(job.PerformInternal(batchScope));
205+
jobTasks.Add(job.Perform(batchScope.ServiceProvider));
206206
}
207207
else
208208
{
209209
var scope = _scopeFactory.CreateScope();
210-
var jobTask = job.PerformInternal(scope);
210+
var jobTask = job.Perform(scope.ServiceProvider);
211211

212212
jobTasks.Add(jobTask);
213213
jobScopes.Value.Add(scope);

0 commit comments

Comments
 (0)