DisconnectWhen implemented

fedeAlterio · Dec 20, 2024 · 79f3839 · 79f3839
1 parent 20ec264
commit 79f3839
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 14 deletions.
diff --git a/SignalsDotnet/SignalsDotnet/Helpers/ObservableEx.cs b/SignalsDotnet/SignalsDotnet/Helpers/ObservableEx.cs
@@ -6,18 +6,13 @@ public static class ObservableEx
 {
     public static Observable<T> DisconnectWhen<T>(this Observable<T> @this, Observable<bool> isDisconnected)
     {
-        throw new InvalidOperationException();
-        //return isDisconnected.Prepend(true)
-        //                     .DistinctUntilChanged()
-        //                     .Replay(1)
-        //                     .AutoConnect(0)
-        //                     .Select(x => x switch
-        //                     {
-        //                         false => @this,
-        //                         true => Observable.Empty<T>()
-        //                     })
-        //                     .Switch()
-        //                     .Publish()
-        //                     .RefCount();
+        return isDisconnected.Select(x => x switch
+                             {
+                                 false => @this,
+                                 true => Observable.Empty<T>()
+                             })
+                             .Switch()
+                             .Publish()
+                             .RefCount();
     }
 }
diff --git a/SignalsDotnet/SignalsDotnet/SignalsDotnet.csproj b/SignalsDotnet/SignalsDotnet/SignalsDotnet.csproj
@@ -7,7 +7,7 @@
     <Description>Porting of Angular signals to dotnet</Description>
     <PackageReadmeFile>README.md</PackageReadmeFile>
     <RepositoryUrl>https://github.com/fedeAlterio/SignalsDotnet</RepositoryUrl>
-    <Version>2.0.1-alpha</Version>
+    <Version>2.0.2-alpha</Version>
   </PropertyGroup>
 
   <ItemGroup>