diff --git a/src/Avalonia.Base/Data/Core/StreamNode.cs b/src/Avalonia.Base/Data/Core/StreamNode.cs
index 023999f5c5..e868b71fcd 100644
--- a/src/Avalonia.Base/Data/Core/StreamNode.cs
+++ b/src/Avalonia.Base/Data/Core/StreamNode.cs
@@ -20,7 +20,7 @@ namespace Avalonia.Data.Core
 
         protected override void StartListeningCore(WeakReference<object> reference)
         {
-            GetPlugin(reference)?.Start(reference).Subscribe(ValueChanged);
+            _subscription = GetPlugin(reference)?.Start(reference).Subscribe(ValueChanged);
         }
 
         protected override void StopListeningCore()