Improved stability of pending task dictionary.

KristofferStrube · Jun 18, 2024 · e473c50 · e473c50
1 parent a0b8ffa
commit e473c50
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/src/KristofferStrube.Blazor.WebWorkers/JobWorker.cs b/src/KristofferStrube.Blazor.WebWorkers/JobWorker.cs
@@ -39,7 +39,10 @@ public async Task<TOutput> ExecuteAsync(TInput input)
             await eventListener.DisposeAsync();
 
             JSONJob<object, object>.JobResponse response = await e.GetDataAsync<JSONJob<object, object>.JobResponse>();
-            pendingTasks[response.RequestIdentifier].SetResult(JsonSerializer.Deserialize<TOutput>(response.OutputSerialized)!);
+            if (pendingTasks.Remove(response.RequestIdentifier, out var successTaskCompletionSource))
+            {
+                successTaskCompletionSource.SetResult(JsonSerializer.Deserialize<TOutput>(response.OutputSerialized)!);
+            }
         });
 
         await AddOnMessageEventListenerAsync(eventListener);