Fix memory leak by using CommandContext.CancellationToken in BackgroundCommandSenderHostedService

Copilot · sfmskywalker · Copilot · commit 6ad44cadf92d · 2025-07-24T21:59:00.000Z
Co-authored-by: sfmskywalker &lt;938393+sfmskywalker@users.noreply.github.com&gt;
diff --git a/src/common/Elsa.Mediator/HostedServices/BackgroundCommandSenderHostedService.cs b/src/common/Elsa.Mediator/HostedServices/BackgroundCommandSenderHostedService.cs
@@ -62,7 +62,7 @@ private async Task ReadOutputAsync(Channel<CommandContext> output, CancellationT
                 using var scope = _scopeFactory.CreateScope();
                 var commandSender = scope.ServiceProvider.GetRequiredService<ICommandSender>();
 
-                await commandSender.SendAsync(commandContext.Command, CommandStrategy.Default, commandContext.Headers, cancellationToken);
+                await commandSender.SendAsync(commandContext.Command, CommandStrategy.Default, commandContext.Headers, commandContext.CancellationToken);
             }
             catch (Exception e)
             {

Original file line number	Diff line number	Diff line change
`@@ -62,7 +62,7 @@ private async Task ReadOutputAsync(Channel<CommandContext> output, CancellationT`
`62`	`62`	`using var scope = _scopeFactory.CreateScope();`
`63`	`63`	`var commandSender = scope.ServiceProvider.GetRequiredService<ICommandSender>();`
`64`	`64`
`65`		`- await commandSender.SendAsync(commandContext.Command, CommandStrategy.Default, commandContext.Headers, cancellationToken);`
	`65`	`+ await commandSender.SendAsync(commandContext.Command, CommandStrategy.Default, commandContext.Headers, commandContext.CancellationToken);`
`66`	`66`	`}`
`67`	`67`	`catch (Exception e)`
`68`	`68`	`{`