Added tests to cover reactivemarbles#668

JakenVeina · Nov 14, 2023 · a1880d0 · a1880d0
1 parent 76d21d4
commit a1880d0
Show file tree

Hide file tree

Showing 2 changed files with 36 additions and 0 deletions.
diff --git a/src/DynamicData.Tests/Cache/DisposeManyFixture.cs b/src/DynamicData.Tests/Cache/DisposeManyFixture.cs
@@ -52,6 +52,24 @@ public void Dispose()
         _results.Dispose();
     }
 
+    [Fact]
+    // Verifies https://github.com/reactivemarbles/DynamicData/issues/668
+    public void ErrorsArePropagated()
+    {
+        var error = new Exception("Test Exception");
+
+        var source = Observable.Throw<IChangeSet<object, object>>(error)
+            .DisposeMany();
+
+        FluentActions.Invoking(() => source.Subscribe()).Should().Throw<Exception>().Which.Should().BeSameAs(error);
+
+        var receivedError = null as Exception;
+        source.Subscribe(
+            onNext: static _ => { },
+            onError: error => receivedError = error);
+        receivedError.Should().BeSameAs(error);
+    }
+
     [Fact]
     public void ItemsAreDisposedAfterRemovalOrReplacement()
     {

diff --git a/src/DynamicData.Tests/List/DisposeManyFixture.cs b/src/DynamicData.Tests/List/DisposeManyFixture.cs
@@ -58,6 +58,24 @@ public void Dispose()
         _results.Dispose();
     }
 
+    [Fact]
+    // Verifies https://github.com/reactivemarbles/DynamicData/issues/668
+    public void ErrorsArePropagated()
+    {
+        var error = new Exception("Test Exception");
+
+        var source = Observable.Throw<IChangeSet<object>>(error)
+            .DisposeMany();
+
+        FluentActions.Invoking(() => source.Subscribe()).Should().Throw<Exception>().Which.Should().BeSameAs(error);
+
+        var receivedError = null as Exception;
+        source.Subscribe(
+            onNext: static _ => { },
+            onError: error => receivedError = error);
+        receivedError.Should().BeSameAs(error);
+    }
+
     [Fact]
     public void ItemsAreDisposedAfterRemovalOrReplacement()
     {