cleanup

Author: stevensJourney

core/src/commonMain/kotlin/com/powersync/db/PowerSyncDatabaseImpl.kt

@@ -139,10 +139,12 @@ internal class PowerSyncDatabaseImpl(
             }
         }
 
-        uploadJob = 
+        uploadJob =
             scope.launch {
-                internalDb.updatesOnTables(setOf(InternalTable.CRUD.toString()))
-                    .debounce(crudThrottleMs).collect {
+                internalDb
+                    .updatesOnTables(setOf(InternalTable.CRUD.toString()))
+                    .debounce(crudThrottleMs)
+                    .collect {
                         syncStream!!.triggerCrudUpload()
                     }
             }
@@ -211,8 +213,7 @@ internal class PowerSyncDatabaseImpl(
         }
     }
 
-    override suspend fun getPowerSyncVersion(): String =
-        internalDb.queries.powerSyncVersion().executeAsOne()
+    override suspend fun getPowerSyncVersion(): String = internalDb.queries.powerSyncVersion().executeAsOne()
 
     override suspend fun <RowType : Any> get(
         sql: String,
@@ -239,11 +240,9 @@ internal class PowerSyncDatabaseImpl(
         mapper: (SqlCursor) -> RowType,
     ): Flow<List<RowType>> = internalDb.watch(sql, parameters, throttleMs, mapper)
 
-    override suspend fun <R> readTransaction(callback: ThrowableTransactionCallback<R>): R =
-        internalDb.writeTransaction(callback)
+    override suspend fun <R> readTransaction(callback: ThrowableTransactionCallback<R>): R = internalDb.writeTransaction(callback)
 
-    override suspend fun <R> writeTransaction(callback: ThrowableTransactionCallback<R>): R =
-        internalDb.writeTransaction(callback)
+    override suspend fun <R> writeTransaction(callback: ThrowableTransactionCallback<R>): R = internalDb.writeTransaction(callback)
 
     override suspend fun execute(
         sql: String,
@@ -288,7 +287,7 @@ internal class PowerSyncDatabaseImpl(
         currentStatus.update(
             connected = false,
             connecting = false,
-            lastSyncedAt = currentStatus.lastSyncedAt
+            lastSyncedAt = currentStatus.lastSyncedAt,
         )
     }