File tree Expand file tree Collapse file tree 2 files changed +4
-4
lines changed Expand file tree Collapse file tree 2 files changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -527,7 +527,7 @@ mixin PowerSyncDatabaseMixin implements SqliteConnection {
527527 /// Unlike [getCrudBatch] , this only returns data from a single transaction at a time.
528528 /// All data for the transaction is loaded into memory.
529529 Future <CrudTransaction ?> getNextCrudTransaction () {
530- return nextCrudTransactions ().firstOrNull;
530+ return getCrudTransactions ().firstOrNull;
531531 }
532532
533533 /// Returns a stream of completed transactions with local writes against the
@@ -567,7 +567,7 @@ mixin PowerSyncDatabaseMixin implements SqliteConnection {
567567 ///
568568 /// If there is no local data to upload, the stream emits a single `onDone`
569569 /// event.
570- Stream <CrudTransaction > nextCrudTransactions () async * {
570+ Stream <CrudTransaction > getCrudTransactions () async * {
571571 var lastCrudItemId = - 1 ;
572572 const sql = '''
573573WITH RECURSIVE crud_entries AS (
Original file line number Diff line number Diff line change @@ -280,15 +280,15 @@ void main() {
280280 });
281281 }
282282
283- await expectLater (powersync.nextCrudTransactions (), emitsDone);
283+ await expectLater (powersync.getCrudTransactions (), emitsDone);
284284
285285 await createTransaction (5 );
286286 await createTransaction (10 );
287287 await createTransaction (15 );
288288
289289 CrudTransaction ? lastTransaction;
290290 final batch = < CrudEntry > [];
291- await for (final transaction in powersync.nextCrudTransactions ()) {
291+ await for (final transaction in powersync.getCrudTransactions ()) {
292292 batch.addAll (transaction.crud);
293293 lastTransaction = transaction;
294294
You can’t perform that action at this time.
0 commit comments