Changelog + OnChange test

Author: LucDeCaf

PowerSync/PowerSync.Common/CHANGELOG.md

@@ -2,6 +2,7 @@
 
 ## 0.0.11-alpha.1
 
+- Implemented throttling for `Watch<T>` and `OnChange` (default 30ms).
 - `StatusUpdated` and `StatusChanged` now both emit `SyncStatus` objects instead of just `StatusChanged`.
 - Converted most instances of a class inheriting from `EventStream<T>` into a class with an `EventManager` property called `Events`. This allows for subscribing to individual events instead of subscribing to all events and then filtering events manually.
 

Tests/PowerSync/PowerSync.Common.Tests/Client/PowerSyncDatabaseTests.cs

@@ -1067,4 +1067,35 @@ public async Task Watch_SingleEventForBatchedQuery()
         Assert.Equal(1, eventCount);
         Assert.Equal(QUERY_COUNT, lastCount);
     }
+
+    [Fact]
+    public async Task OnChange_SingleEventsForBatchedQuery()
+    {
+        int eventCount = 0;
+        var tcs = new TaskCompletionSource<bool>();
+
+        var listener = db.OnChange(new()
+        {
+            Tables = ["assets"],
+            Signal = testCts.Token,
+        });
+
+        _ = Task.Run(async () =>
+        {
+            await foreach (var _ in listener)
+            {
+                Interlocked.Increment(ref eventCount);
+            }
+            tcs.TrySetResult(true);
+        });
+
+        // Long batched query
+        const int QUERY_COUNT = 10000;
+        await TestUtils.InsertRandomAssets(db, QUERY_COUNT);
+
+        testCts.Cancel();
+        Assert.True(await tcs.Task);
+
+        Assert.Equal(1, eventCount);
+    }
 }