Fix watch test + potential deathloop

Author: LucDeCaf

PowerSync/PowerSync.Common/Client/PowerSyncDatabase.cs

@@ -882,7 +882,7 @@ IAsyncEnumerable<DBAdapterEvent> initialListener
                 powersyncTables,
                 currentListener,
                 currentRestartCts.Token,
-                isRestart || options?.TriggerImmediately == true
+                isRestart || (options?.TriggerImmediately == true)
             ).GetAsyncEnumerator(currentRestartCts.Token);
 
             // Continually wait for either OnChange or SchemaChanged to fire
@@ -972,6 +972,8 @@ private async IAsyncEnumerable<WatchOnChangeEvent> OnRawTableChange(
                 GetTablesFromNotification(e.TablesUpdated, changedTables);
                 changedTables.IntersectWith(watchedTables);
 
+                if (changedTables.Count == 0) continue;
+
                 yield return new WatchOnChangeEvent { ChangedTables = [.. changedTables] };
             }
         }

PowerSync/PowerSync.Common/Client/Sync/Stream/StreamingSyncTypes.cs

@@ -97,7 +97,7 @@ public class RequestStreamSubscription
     [JsonProperty("parameters")]
     public Dictionary<string, object> Parameters { get; set; } = new();
 
-    [JsonProperty("override_priority", NullValueHandling = NullValueHandling.Ignore)]
+    [JsonProperty("override_priority")]
     public int? OverridePriority { get; set; }
 
 }

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

@@ -706,13 +706,11 @@ public async Task WatchSchemaResetTest()
             {
                 await foreach (var result in listener)
                 {
-                    if (result.Length > 0)
-                    {
-                        lastCount = result[0].count;
-                    }
+                    lastCount = result[0].count;
                     sem.Release();
                 }
-            });
+            }, testCts.Token);
+            Assert.False(await sem.WaitAsync(200));
 
             var resolved = await db.GetSourceTables(QUERY, null);
             Assert.Single(resolved);