Small code style improvement.

Wouterdek · Dec 29, 2017 · 876b155 · 876b155
1 parent 14f73d9
commit 876b155
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/NodeNetworkToolkit/ValueNode/ValueNodeInputViewModel.cs b/NodeNetworkToolkit/ValueNode/ValueNodeInputViewModel.cs
@@ -3,6 +3,7 @@
 using System.Linq;
 using System.Reactive;
 using System.Reactive.Concurrency;
+using System.Reactive.Disposables;
 using System.Reactive.Linq;
 using System.Reactive.Subjects;
 using System.Reactive.Threading.Tasks;
@@ -102,8 +103,9 @@ public ValueNodeInputViewModel(
             ValueChanged = Observable.Create<T>(observer =>
             {
                 observer.OnNext(Value);
-                return valueChanged.Subscribe(observer.OnNext, observer.OnError, observer.OnCompleted);
-            });
+                observer.OnCompleted();
+                return Disposable.Empty;
+            }).Concat(valueChanged);
         }
 
         private IObservable<T> GenerateConnectedValuesBinding(ValidationAction connectionChangedValidationAction, ValidationAction connectedValueChangedValidationAction)