File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -122,6 +122,7 @@ export class PowerSyncTauriDatabase extends AbstractPowerSyncDatabase {
122122 name,
123123 parameters,
124124 async subscribe ( options ?: SyncStreamSubscribeOptions ) : Promise < SyncStreamSubscription > {
125+ await database . init ( ) ;
125126 const result = await powersyncCommand ( {
126127 SubscribeToStream : {
127128 database : database . rustHandle ,
@@ -165,15 +166,15 @@ export class PowerSyncTauriDatabase extends AbstractPowerSyncDatabase {
165166
166167 async _initialize ( ) : Promise < void > {
167168 const path = await this . resolvePath ( ) ;
168- this . tableUpdateListener = await listen < string [ ] > ( `table-updates:${ name } ` , ( event ) => {
169+ this . tableUpdateListener = await listen < string [ ] > ( `table-updates:${ path } ` , ( event ) => {
169170 const adapter = this . database ;
170171 if ( adapter instanceof RustDatabaseAdapter ) {
171172 adapter . iterateListeners ( ( l ) =>
172173 l . tablesUpdated ?.( { tables : event . payload , rawUpdates : [ ] , groupedUpdates : { } } )
173174 ) ;
174175 }
175176 } ) ;
176- this . syncStatusListener = await listen < SyncStatusOptions > ( `sync-status:${ name } ` , ( event ) => {
177+ this . syncStatusListener = await listen < SyncStatusOptions > ( `sync-status:${ path } ` , ( event ) => {
177178 this . updateSyncStatusFromRust ( event . payload ) ;
178179 } ) ;
179180
You can’t perform that action at this time.
0 commit comments