Pass main loop token forward

danielmarbach · danielmarbach · commit 3dafe82823e8 · 2025-10-12T16:19:41.000+02:00
diff --git a/projects/RabbitMQ.Client/Impl/Connection.Heartbeat.cs b/projects/RabbitMQ.Client/Impl/Connection.Heartbeat.cs
@@ -109,7 +109,7 @@ private async void HeartbeatReadTimerCallback(object? state)
                     {
                         var eose = new EndOfStreamException($"Heartbeat missing with heartbeat == {_heartbeat} seconds");
                         LogCloseError(eose.Message, eose);
-                        await HandleMainLoopExceptionAsync(new ShutdownEventArgs(ShutdownInitiator.Library, 0, "End of stream", eose))
+                        await HandleMainLoopExceptionAsync(new ShutdownEventArgs(ShutdownInitiator.Library, 0, "End of stream", eose, _mainLoopCts.Token))
                             .ConfigureAwait(false);
                         shouldTerminate = true;
                     }

Original file line number	Diff line number	Diff line change
`@@ -109,7 +109,7 @@ private async void HeartbeatReadTimerCallback(object? state)`
`109`	`109`	`{`
`110`	`110`	`var eose = new EndOfStreamException($"Heartbeat missing with heartbeat == {_heartbeat} seconds");`
`111`	`111`	`LogCloseError(eose.Message, eose);`
`112`		`- await HandleMainLoopExceptionAsync(new ShutdownEventArgs(ShutdownInitiator.Library, 0, "End of stream", eose))`
	`112`	`+ await HandleMainLoopExceptionAsync(new ShutdownEventArgs(ShutdownInitiator.Library, 0, "End of stream", eose, _mainLoopCts.Token))`
`113`	`113`	`.ConfigureAwait(false);`
`114`	`114`	`shouldTerminate = true;`
`115`	`115`	`}`