Fix Watch

LucDeCaf · LucDeCaf · commit e7fa47f95427 · 2026-01-22T13:12:06.000+02:00
diff --git a/PowerSync/PowerSync.Common/Client/PowerSyncDatabase.cs b/PowerSync/PowerSync.Common/Client/PowerSyncDatabase.cs
@@ -697,7 +697,7 @@ private Task WatchInternal<T>(
             try
             {
                 var resolvedTables = await ResolveTables(query, parameters, options);
-                var result = await GetAll<T>(query, parameters);
+                var result = await getter(query, parameters);
                 handler.OnResult(result);
 
                 OnChange(new WatchOnChangeHandler

Original file line number	Diff line number	Diff line change
`@@ -697,7 +697,7 @@ private Task WatchInternal<T>(`
`697`	`697`	`try`
`698`	`698`	`{`
`699`	`699`	`var resolvedTables = await ResolveTables(query, parameters, options);`
`700`		`- var result = await GetAll<T>(query, parameters);`
	`700`	`+ var result = await getter(query, parameters);`
`701`	`701`	`handler.OnResult(result);`
`702`	`702`
`703`	`703`	`OnChange(new WatchOnChangeHandler`