Fix: AsObservable immediately calls Dispose on completion

src/R3/Operators/AsObservable.cs

@@ -22,7 +22,32 @@ internal sealed class AsObservable<T>(Observable<T> observable) : Observable<T>
 {
     protected override IDisposable SubscribeCore(Observer<T> observer)
     {
-        return observable.Subscribe(observer.Wrap());
+        return observable.Subscribe(new AsObservableObserver(observer));
+    }
+
+    sealed class AsObservableObserver(Observer<T> observer) : Observer<T>
+    {
+        protected override bool AutoDisposeOnCompleted => false;
+
+        protected override void OnNextCore(T value)
+        {
+            observer.OnNext(value);
+        }
+
+        protected override void OnErrorResumeCore(Exception error)
+        {
+            observer.OnErrorResume(error);
+        }
+
+        protected override void OnCompletedCore(Result result)
+        {
+            observer.OnCompleted(result);
+        }
+
+        protected override void DisposeCore()
+        {
+            observer.Dispose();
+        }
     }
 }
 
@@ -35,6 +60,8 @@ public IDisposable Subscribe(IObserver<T> observer)
 
     sealed class ObserverToObserver(IObserver<T> observer) : Observer<T>
     {
+        protected override bool AutoDisposeOnCompleted => false;
+
         protected override void OnNextCore(T value)
         {
             observer.OnNext(value);

tests/R3.Tests/OperatorTests/AsObservableTest.cs

@@ -18,9 +18,25 @@ public void AsObservable()
     }
 
     [Fact]
-    public void AsSystemObservable()
+    public void AsObservableWithDelay()
     {
+        var p = new Subject<int>();
+        var fakeFrameProvider = new FakeFrameProvider();
+
+        var l = p.AsObservable().DelayFrame(1, fakeFrameProvider).ToLiveList();
+        p.OnNext(1);
+        p.OnNext(2);
+        p.OnNext(3);
+        p.OnCompleted();
+        fakeFrameProvider.Advance();
 
+        l.AssertEqual([1, 2, 3]);
+        l.AssertIsCompleted();
+    }
+
+    [Fact]
+    public void AsSystemObservable()
+    {
         {
             var p = new Subject<int>();
             var l = new List<int>();