fix(database): fix a regression with database localEvents handling

packages/firebase_database/firebase_database/android/src/main/kotlin/io/flutter/plugins/firebase/database/FirebaseDatabasePlugin.kt

@@ -770,7 +770,7 @@ class FirebaseDatabasePlugin :
             callback(KotlinResult.success(Unit))
           }
         }
-      })
+      }, request.applyLocally)
     } catch (e: Exception) {
       // Convert generic exceptions to FlutterFirebaseDatabaseException for proper error handling
       val flutterException = if (e is FlutterFirebaseDatabaseException) e else FlutterFirebaseDatabaseException.unknown(e.message ?: "Unknown transaction error")

packages/firebase_database/firebase_database/ios/firebase_database/Sources/firebase_database/FLTFirebaseDatabasePlugin.swift

@@ -251,7 +251,7 @@ public class FLTFirebaseDatabasePlugin: NSObject, FlutterPlugin, FLTFirebasePlug
     let database = getDatabaseFromPigeonApp(app)
     let reference = database.reference(withPath: request.path)
 
-    reference.runTransactionBlock { currentData in
+    reference.runTransactionBlock({ currentData in
       let semaphore = DispatchSemaphore(value: 0)
       var transactionResult: TransactionHandlerResult?
 
@@ -284,7 +284,7 @@ public class FLTFirebaseDatabasePlugin: NSObject, FlutterPlugin, FLTFirebasePlug
 
       currentData.value = result.value
       return TransactionResult.success(withValue: currentData)
-    } andCompletionBlock: { error, committed, snapshot in
+    }, andCompletionBlock: { error, committed, snapshot in
       if let error {
         completion(.failure(self.createFlutterError(error)))
         return
@@ -304,7 +304,7 @@ public class FLTFirebaseDatabasePlugin: NSObject, FlutterPlugin, FLTFirebasePlug
       ]
 
       completion(.success(()))
-    }
+    }, withLocalEvents: request.applyLocally)
   }
 
   func databaseReferenceGetTransactionResult(app: DatabasePigeonFirebaseApp, transactionKey: Int64,

tests/integration_test/firebase_database/database_reference_e2e.dart

@@ -126,6 +126,41 @@ void setupDatabaseReferenceTests() {
         expect(result.snapshot.value, 5);
       });
 
+      test('does not emit local transaction events when disabled', () async {
+        final ref = database.ref('tests/transaction-apply-locally-false');
+        await ref.set({'count': 0});
+
+        final initialEvent = Completer<void>();
+        final events = <Object?>[];
+        final subscription = ref.onValue.listen((event) {
+          if (!initialEvent.isCompleted) {
+            initialEvent.complete();
+            return;
+          }
+
+          events.add(event.snapshot.value);
+        });
+
+        try {
+          await initialEvent.future.timeout(const Duration(seconds: 5));
+
+          await ref.runTransaction(
+            (value) => Transaction.success({
+              'count': ((value as Map?)?['count'] as int? ?? 0) + 1,
+              'timestamp': ServerValue.timestamp,
+            }),
+            applyLocally: false,
+          );
+
+          await Future<void>.delayed(const Duration(seconds: 1));
+
+          expect(events, hasLength(1));
+        } finally {
+          await database.goOnline();
+          await subscription.cancel();
+        }
+      });
+
       test('executes transaction', () async {
         final ref = database.ref('tests/transaction-exec');
         await ref.set(0);