File tree Expand file tree Collapse file tree 1 file changed +2
-1
lines changed
src/Transports.Subscriptions.Abstractions Expand file tree Collapse file tree 1 file changed +2
-1
lines changed Original file line number Diff line number Diff line change @@ -72,11 +72,12 @@ public void OnError(Exception error)
7272 // pass along the error as an execution result instance
7373 OnNext ( new ExecutionResult { Errors = new ExecutionErrors { executionError } } ) ;
7474
75- // Optionally we can disconnect the client by calling OnComplete() here
75+ // Disconnect the client as no additional notification should be received from the source
7676 //
7777 // https://docs.microsoft.com/en-us/dotnet/standard/events/observer-design-pattern-best-practices
7878 // > Once the provider calls the OnError or IObserver<T>.OnCompleted method, there should be
7979 // > no further notifications, and the provider can unsubscribe its observers.
80+ OnCompleted ( ) ;
8081 }
8182
8283 public void OnNext ( ExecutionResult value )
You can’t perform that action at this time.
0 commit comments