From f8f3ba2bd9199637a166aaf59d14d42ed44bb841 Mon Sep 17 00:00:00 2001
From: Austin Hale <ahale@nakamir.com>
Date: Tue, 9 Jun 2026 18:41:15 -0700
Subject: [PATCH] fix: flush table-update notifications while holding the write
 mutex

---
 PowerSync/PowerSync.Common/MDSQLite/MDSQLiteAdapter.cs | 7 ++-----
 1 file changed, 2 insertions(+), 5 deletions(-)

diff --git a/PowerSync/PowerSync.Common/MDSQLite/MDSQLiteAdapter.cs b/PowerSync/PowerSync.Common/MDSQLite/MDSQLiteAdapter.cs
index 5ae03cf..9d71447 100644
--- a/PowerSync/PowerSync.Common/MDSQLite/MDSQLiteAdapter.cs
+++ b/PowerSync/PowerSync.Common/MDSQLite/MDSQLiteAdapter.cs
@@ -248,10 +248,8 @@ public async Task WriteLock(Func<ILockContext, Task> fn, DBLockOptions? options
         using (await writeMutex.LockAsync())
         {
             await fn(writeConnection);
+            writeConnection.FlushUpdates();
         }
-
-        writeConnection.FlushUpdates();
-
     }
 
     public async Task<T> WriteLock<T>(Func<ILockContext, Task<T>> fn, DBLockOptions? options = null)
@@ -262,10 +260,9 @@ public async Task<T> WriteLock<T>(Func<ILockContext, Task<T>> fn, DBLockOptions?
         using (await writeMutex.LockAsync())
         {
             result = await fn(writeConnection);
+            writeConnection.FlushUpdates();
         }
 
-        writeConnection.FlushUpdates();
-
         return result;
     }