Signal completion even when no observers.

4 years ago · fcdabffe24
1 changed files with 4 additions and 2 deletions
--- a/src/Avalonia.Base/Reactive/SingleSubscriberObservableBase.cs
+++ b/src/Avalonia.Base/Reactive/SingleSubscriberObservableBase.cs
@ -51,10 +51,11 @@ namespace Avalonia.Reactive

        protected void PublishCompleted()
        {
+            _completed = true;
+
            if (_observer != null)
            {
                _observer.OnCompleted();
-                _completed = true;
                Unsubscribed();
                _observer = null;
            }
@ -62,10 +63,11 @@ namespace Avalonia.Reactive

        protected void PublishError(Exception error)
        {
+            _error = error;
+
            if (_observer != null)
            {
                _observer.OnError(error);
-                _error = error;
                Unsubscribed();
                _observer = null;
            }