We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 2fdf71d commit eca1ac9Copy full SHA for eca1ac9
src/core/Akka.Streams/Implementation/Fusing/Ops.cs
@@ -3817,19 +3817,7 @@ public override void OnDownstreamFinish()
3817
_completionCts.Cancel();
3818
_completionCts.Dispose();
3819
3820
- try
3821
- {
3822
- _enumerator.DisposeAsync().GetAwaiter().GetResult();
3823
- }
3824
- catch (Exception ex)
3825
3826
- Log.Warning(ex, "Failed to dispose IAsyncEnumerator asynchronously");
3827
3828
- finally
3829
3830
- CompleteStage();
3831
- base.OnDownstreamFinish();
3832
+ CompleteStage();
3833
base.OnDownstreamFinish();
3834
}
3835
0 commit comments