Updates: catch Exception at async enumeration

Leksiqq · Mar 25, 2022 · af28cd1 · af28cd1
1 parent 5d6a6ef
commit af28cd1
Showing 1 changed file with 9 additions and 2 deletions.
diff --git a/Library/PartialLoader.cs b/Library/PartialLoader.cs
@@ -596,7 +596,10 @@ private void PrepareToExecute()
 
         _loadTask = Task.Run(async () =>
         {
-            await foreach (T item in _dataProvider!.ConfigureAwait(false))
+            await foreach (
+                T item in _dataProvider!
+                .ConfigureAwait(false)
+            )
             {
                 if (_cancellationTokenSource.Token.IsCancellationRequested)
                 {
@@ -605,9 +608,13 @@ private void PrepareToExecute()
                 _queue.Enqueue(item);
                 _manualReset.Set();
             }
-        }).ContinueWith(_ =>
+        }).ContinueWith(t =>
         {
             _manualReset.Set();
+            if (t.IsFaulted)
+            {
+                throw t.Exception;
+            }
         });
     }