Clear the enumerator in OnNext

dotnet · Nov 14, 2019 · 87aa2b0 · 87aa2b0
1 parent 628cba8
commit 87aa2b0
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/Rx.NET/Source/src/System.Reactive/Linq/Observable/Zip.cs b/Rx.NET/Source/src/System.Reactive/Linq/Observable/Zip.cs
@@ -353,7 +353,7 @@ public override void OnNext(TFirst value)
                         {
                             if (Interlocked.Decrement(ref _enumerationInProgress) != 0)
                             {
-                                currentEnumerator.Dispose();
+                                Interlocked.Exchange(ref _rightEnumerator, DisposedEnumerator)?.Dispose();
                                 wasDisposed = true;
                             }
                         }