IgnoreElements

sandbox/ConsoleApp1/Program.cs

@@ -33,6 +33,19 @@
 
 Enumerable.Range(1, 10).Cast<int>();
 
+
+var a = range.Publish();
+
+
+// BehaviourSubject -> ReactiveProperty
+// ReplaySubject
+
+
+
+
+a.Connect();
+
+
 // range.Catch(
 // range.Append(
 

src/R3/Operators/CombineLatest.cs

@@ -1,5 +1,6 @@
 //namespace R3;
 
+//TODO:not yet implemented.
 //public static partial class EventExtensions
 //{
 //    public static Event<TResult> CombineLatest<TLeft, TRight, TResult>(

src/R3/Operators/Delay.cs

@@ -2,6 +2,7 @@
 
 namespace R3;
 
+//TODO:not yet implemented.
 public static partial class ObservableExtensions
 {
     //public static Event<T> Delay<T>(this Event<T> source, TimeSpan dueTime, TimeProvider timeProvider)

src/R3/Operators/IgnoreElements.cs

@@ -0,0 +1,34 @@
+namespace R3;
+
+public static partial class ObservableExtensions
+{
+    public static Observable<T> IgnoreElements<T>(this Observable<T> source)
+    {
+        return new IgnoreElements<T>(source);
+    }
+}
+
+internal sealed class IgnoreElements<T>(Observable<T> source) : Observable<T>
+{
+    protected override IDisposable SubscribeCore(Observer<T> observer)
+    {
+        return source.Subscribe(new _IgnoreElements(observer));
+    }
+
+    sealed class _IgnoreElements(Observer<T> observer) : Observer<T>
+    {
+        protected override void OnNextCore(T value)
+        {
+        }
+
+        protected override void OnErrorResumeCore(Exception error)
+        {
+            observer.OnErrorResume(error);
+        }
+
+        protected override void OnCompletedCore(Result result)
+        {
+            observer.OnCompleted(result);
+        }
+    }
+}

src/R3/Operators/OfType.cs

@@ -36,4 +36,3 @@ protected override void OnCompletedCore(Result result)
         }
     }
 }
-

src/R3/Operators/_Operators.cs

@@ -30,4 +30,7 @@ public static partial class ObservableExtensions
 
     // return tasks:
     // All, Any, Contains, SequenceEqual, IsEmpty, MaxBy, MinBy, ToDictionary, ToLookup,
+
+    // Multicast
+    // Multicast, Publish, Replay, RefCount, Share(Publish().RefCount()), AutoConnect
 }

tests/R3.Tests/OperatorTests/IgnoreElementsTest.cs

@@ -0,0 +1,22 @@
+namespace R3.Tests.OperatorTests;
+
+public class IgnoreElementsTest
+{
+    [Fact]
+    public void Test()
+    {
+        var subject = new Subject<int>();
+        using var list = subject.IgnoreElements().ToLiveList();
+
+        subject.OnNext(10);
+        subject.OnNext(20);
+        subject.OnNext(30);
+
+        list.AssertEqual([]);
+        list.AssertIsNotCompleted();
+
+        subject.OnCompleted();
+
+        list.AssertIsCompleted();
+    }
+}