Another test

Author: simolus3

core/src/commonIntegrationTest/kotlin/com/powersync/DatabaseTest.kt

@@ -1,5 +1,6 @@
 package com.powersync
 
+import app.cash.turbine.test
 import app.cash.turbine.turbineScope
 import co.touchlab.kermit.ExperimentalKermitApi
 import com.powersync.db.ActiveDatabaseGroup
@@ -441,6 +442,9 @@ class DatabaseTest {
                 }
             }
 
+            // Before inserting data, the flow should be empty
+            database.getCrudTransactions().test { awaitComplete() }
+
             insertInTransaction(5)
             insertInTransaction(10)
             insertInTransaction(15)

core/src/commonMain/kotlin/com/powersync/PowerSyncDatabase.kt

@@ -137,7 +137,7 @@ public interface PowerSyncDatabase : Queries {
     public suspend fun getNextCrudTransaction(): CrudTransaction? = getCrudTransactions().firstOrNull()
 
     /**
-     * Obtains a flow of transactions with local data against the database.
+     * Obtains a flow emitting completed transactions with local writes against the database.
 
      * This is typically used from the [PowerSyncBackendConnector.uploadData] callback.
      * Each entry emitted by the returned flow is a full transaction containing all local writes
@@ -154,7 +154,7 @@ public interface PowerSyncDatabase : Queries {
      * val batch = mutableListOf<CrudEntry>()
      * var lastTx: CrudTransaction? = null
      *
-     * database.getCrudTransactions().takeWhile { batch.size < 10 }.collect {
+     * database.getCrudTransactions().takeWhile { batch.size < 100 }.collect {
      *   batch.addAll(it.crud)
      *   lastTx = it
      * }