diff --git a/src/Orleans.Streaming/Core/IAsyncObserver.cs b/src/Orleans.Streaming/Core/IAsyncObserver.cs
index 96aafcb726..795bf9bf3f 100644
--- a/src/Orleans.Streaming/Core/IAsyncObserver.cs
+++ b/src/Orleans.Streaming/Core/IAsyncObserver.cs
@@ -56,6 +56,6 @@ public interface IAsyncObserver<in T>
         /// </summary>
         /// <param name="ex">An Exception that describes the error that occurred on the stream.</param>
         /// <returns>A Task that is completed when the close has been accepted.</returns>
-        Task OnErrorAsync(Exception ex) => throw ex;
+        Task OnErrorAsync(Exception ex);
     }
 }