@@ -150,7 +150,6 @@ export abstract class AbstractPowerSyncDatabase extends BaseObserver<PowerSyncDB
150150 this . sdkVersion = version . rows ?. item ( 0 ) [ 'powersync_rs_version()' ] ?? '' ;
151151 this . ready = true ;
152152 this . iterateListeners ( ( cb ) => cb . initialized ?.( ) ) ;
153- this . watchCrudUploads ( ) ;
154153 }
155154
156155 /**
@@ -159,11 +158,10 @@ export abstract class AbstractPowerSyncDatabase extends BaseObserver<PowerSyncDB
159158 protected async watchCrudUploads ( ) {
160159 for await ( const event of this . onChange ( {
161160 tables : [ PSInternalTable . CRUD ] ,
162- rawTableNames : true
161+ rawTableNames : true ,
162+ signal : this . abortController ?. signal
163163 } ) ) {
164- if ( this . connected ) {
165- this . syncStreamImplementation ?. triggerCrudUpload ( ) ;
166- }
164+ this . syncStreamImplementation ?. triggerCrudUpload ( ) ;
167165 }
168166 }
169167
@@ -195,6 +193,7 @@ export abstract class AbstractPowerSyncDatabase extends BaseObserver<PowerSyncDB
195193 // Begin network stream
196194 this . syncStreamImplementation . triggerCrudUpload ( ) ;
197195 this . syncStreamImplementation . streamingSync ( this . abortController . signal ) ;
196+ this . watchCrudUploads ( ) ;
198197 }
199198
200199 async disconnect ( ) {
@@ -381,8 +380,7 @@ export abstract class AbstractPowerSyncDatabase extends BaseObserver<PowerSyncDB
381380 */
382381 async execute ( sql : string , parameters ?: any [ ] ) {
383382 await this . waitForReady ( ) ;
384- const result = await this . database . execute ( sql , parameters ) ;
385- return result ;
383+ return this . database . execute ( sql , parameters ) ;
386384 }
387385
388386 /**
0 commit comments