Skip to content

Commit 4c2649e

Browse files
committed
Clean up
1 parent ea28bf6 commit 4c2649e

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

src/SignalR/server/Core/src/Internal/DefaultHubDispatcher.cs

+2-1
Original file line numberDiff line numberDiff line change
@@ -86,7 +86,6 @@ public override async Task OnConnectedAsync(HubConnectionContext connection)
8686

8787
var hubActivator = scope.ServiceProvider.GetRequiredService<IHubActivator<THub>>();
8888
var hub = hubActivator.Create();
89-
9089
Activity? activity = null;
9190
try
9291
{
@@ -396,6 +395,7 @@ static async Task ExecuteInvocation(DefaultHubDispatcher<THub> dispatcher,
396395
var logger = dispatcher._logger;
397396
var enableDetailedErrors = dispatcher._enableDetailedErrors;
398397

398+
// Hub invocation gets its parent from a remote source. Clear any current activity and restore it later.
399399
var previousActivity = Activity.Current;
400400
if (previousActivity != null)
401401
{
@@ -515,6 +515,7 @@ private async Task StreamAsync(string invocationId, HubConnectionContext connect
515515

516516
streamCts ??= CancellationTokenSource.CreateLinkedTokenSource(connection.ConnectionAborted);
517517

518+
// Hub invocation gets its parent from a remote source. Clear any current activity and restore it later.
518519
var previousActivity = Activity.Current;
519520
if (previousActivity != null)
520521
{

0 commit comments

Comments
 (0)