Retain cancel callback until ForEachAsync completes (#1981)

dotnet · Jul 27, 2023 · 5903ac6 · 5903ac6
1 parent dffafe1
commit 5903ac6
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/AsyncRx.NET/System.Reactive.Async/Linq/Operators/ForEachAsync.cs b/AsyncRx.NET/System.Reactive.Async/Linq/Operators/ForEachAsync.cs
@@ -124,9 +124,9 @@ private static async Task ForEachAsyncCore<TSource>(IAsyncObservable<TSource> so
                 var d = await source.SubscribeAsync(o).ConfigureAwait(false);
 
                 await subscription.AssignAsync(d).ConfigureAwait(false);
-            }
 
-            await tcs.Task.ConfigureAwait(false);
+                await tcs.Task.ConfigureAwait(false);
+            }
         }
     }
 }