Fix SQLiter crash

simolus3 · simolus3 · commit 78658d7704ba · 2025-09-23T11:30:49.000+02:00
diff --git a/core/src/commonMain/kotlin/com/powersync/db/StreamImpl.kt b/core/src/commonMain/kotlin/com/powersync/db/StreamImpl.kt
@@ -23,7 +23,7 @@ internal class StreamTracker(
 
     suspend fun subscriptionsCommand(command: RustSubscriptionChangeRequest) {
         db.writeTransaction { tx ->
-            tx.execute("SELECT powersync_control(?,?)", listOf("subscriptions", jsonDontEncodeDefaults.encodeToString(command)))
+            tx.get("SELECT powersync_control(?,?)", listOf("subscriptions", jsonDontEncodeDefaults.encodeToString(command))) {}
         }
         db.resolveOfflineSyncStatusIfNotConnected()
     }

Original file line number	Diff line number	Diff line change
`@@ -23,7 +23,7 @@ internal class StreamTracker(`
`23`	`23`
`24`	`24`	`suspend fun subscriptionsCommand(command: RustSubscriptionChangeRequest) {`
`25`	`25`	`db.writeTransaction { tx ->`
`26`		`- tx.execute("SELECT powersync_control(?,?)", listOf("subscriptions", jsonDontEncodeDefaults.encodeToString(command)))`
	`26`	`+ tx.get("SELECT powersync_control(?,?)", listOf("subscriptions", jsonDontEncodeDefaults.encodeToString(command))) {}`
`27`	`27`	`}`
`28`	`28`	`db.resolveOfflineSyncStatusIfNotConnected()`
`29`	`29`	`}`