From 3a1a60eb2b2eaa739744418dc7b056cde584ec9b Mon Sep 17 00:00:00 2001 From: Ebere Abanonu Date: Fri, 28 Jan 2022 16:43:26 +0100 Subject: [PATCH] Catch `StreamDetachedException` --- src/core/Akka.Streams.Tests/Dsl/AsyncEnumerableSpec.cs | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/src/core/Akka.Streams.Tests/Dsl/AsyncEnumerableSpec.cs b/src/core/Akka.Streams.Tests/Dsl/AsyncEnumerableSpec.cs index 9776e259327..74ca3f8b3d8 100644 --- a/src/core/Akka.Streams.Tests/Dsl/AsyncEnumerableSpec.cs +++ b/src/core/Akka.Streams.Tests/Dsl/AsyncEnumerableSpec.cs @@ -117,6 +117,10 @@ public async Task RunAsAsyncEnumerable_Throws_on_Abrupt_Stream_termination() { await a; } + catch (StreamDetachedException e) + { + thrown = true; + } catch (AbruptTerminationException e) { thrown = true;