Requested changes

Author: theSlyest

Parse.Tests/LiveQuerySubscriptionTests.cs

@@ -120,7 +120,12 @@ public void TestEnter()
             }
         };
 
-        MutableObjectState state = originalState;
+        MutableObjectState state = new() {
+            ObjectId = originalState.ObjectId,
+            ClassName = originalState.ClassName,
+            CreatedAt = originalState.CreatedAt,
+            ServerData = new Dictionary<string, object>(originalState.ServerData)
+        };
         state["key"] = "after";
 
         ParseLiveQuerySubscription<ParseObject> subscription = new(Client.Services, "Corgi", 1);

Parse.Tests/ObjectServiceExtensionsTests.cs

@@ -264,4 +264,25 @@ public void GetFieldForPropertyName_ReturnsExpectedMapping()
         mockHub.Setup(h => h.ClassController).Returns(mockController.Object);
         Assert.AreEqual("field", mockHub.Object.GetFieldForPropertyName("cls", "prop"));
     }
+
+    [TestMethod]
+    public async Task ConnectLiveQueryServerAsync_NullController_Throws()
+    {
+        Mock<IServiceHub> mockHub = new Mock<IServiceHub>();
+        mockHub.Setup(h => h.LiveQueryController).Returns((IParseLiveQueryController)null);
+        await Assert.ThrowsExceptionAsync<InvalidOperationException>(
+            () => mockHub.Object.ConnectLiveQueryServerAsync((s, e) => { }));
+    }
+
+    [TestMethod]
+    public async Task DisconnectLiveQueryServerAsync_CloseThrows_Propagates()
+    {
+        Mock<IServiceHub> mockHub = new Mock<IServiceHub>();
+        Mock<IParseLiveQueryController> mockLq = new Mock<IParseLiveQueryController>();
+        mockLq.Setup(l => l.CloseAsync(It.IsAny<CancellationToken>()))
+              .ThrowsAsync(new Exception("close failed"));
+        mockHub.Setup(h => h.LiveQueryController).Returns(mockLq.Object);
+
+        await Assert.ThrowsExceptionAsync<Exception>(() => mockHub.Object.DisconnectLiveQueryServerAsync());
+    }
 }