diff --git a/Rx.NET/Source/src/System.Reactive/Linq/Observable/Case.cs b/Rx.NET/Source/src/System.Reactive/Linq/Observable/Case.cs
index f30ea69934..46883464f7 100644
--- a/Rx.NET/Source/src/System.Reactive/Linq/Observable/Case.cs
+++ b/Rx.NET/Source/src/System.Reactive/Linq/Observable/Case.cs
@@ -53,7 +53,7 @@ public void Run(Case<TValue, TResult> parent)
                     return;
                 }
 
-                SetUpstream(result.SubscribeSafe(this));
+                base.Run(result);
             }
         }
     }
diff --git a/Rx.NET/Source/src/System.Reactive/Linq/Observable/Defer.cs b/Rx.NET/Source/src/System.Reactive/Linq/Observable/Defer.cs
index d75dee548d..da19cc6f2b 100644
--- a/Rx.NET/Source/src/System.Reactive/Linq/Observable/Defer.cs
+++ b/Rx.NET/Source/src/System.Reactive/Linq/Observable/Defer.cs
@@ -45,7 +45,7 @@ public void Run()
                     return;
                 }
 
-                SetUpstream(result.SubscribeSafe(this));
+                base.Run(result);
             }
         }
     }