diff --git a/src/Argon.Api/Features/Orleanse/Streams/ServerArgonStream.cs b/src/Argon.Api/Features/Orleanse/Streams/ServerArgonStream.cs index 95b8f9bb..7af6ba40 100644 --- a/src/Argon.Api/Features/Orleanse/Streams/ServerArgonStream.cs +++ b/src/Argon.Api/Features/Orleanse/Streams/ServerArgonStream.cs @@ -15,8 +15,7 @@ public Task OnErrorAsync(Exception ex) public IAsyncEnumerator GetAsyncEnumerator(CancellationToken ct = default) => throw new NotImplementedException($"Server stream cannot create async enumerator"); - public async ValueTask DisposeAsync() - => await stream.OnCompletedAsync(); + public async ValueTask DisposeAsync() { } public async ValueTask Fire(T ev) {