From b8a9b15e3a8f554633400bc7cf3f27e9992b3069 Mon Sep 17 00:00:00 2001
From: Daniel Weber <dw@exram.de>
Date: Thu, 21 Jun 2018 13:52:58 +0200
Subject: [PATCH] Use IdentitySink.Run where appropriate.

---
 Rx.NET/Source/src/System.Reactive/Linq/Observable/Case.cs  | 2 +-
 Rx.NET/Source/src/System.Reactive/Linq/Observable/Defer.cs | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

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);
             }
         }
     }