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 {
527
527
/// Unlike [getCrudBatch] , this only returns data from a single transaction at a time.
528
528
/// All data for the transaction is loaded into memory.
529
529
Future <CrudTransaction ?> getNextCrudTransaction () {
530
- return nextCrudTransactions ().firstOrNull;
530
+ return getCrudTransactions ().firstOrNull;
531
531
}
532
532
533
533
/// Returns a stream of completed transactions with local writes against the
@@ -567,7 +567,7 @@ mixin PowerSyncDatabaseMixin implements SqliteConnection {
567
567
///
568
568
/// If there is no local data to upload, the stream emits a single `onDone`
569
569
/// event.
570
- Stream <CrudTransaction > nextCrudTransactions () async * {
570
+ Stream <CrudTransaction > getCrudTransactions () async * {
571
571
var lastCrudItemId = - 1 ;
572
572
const sql = '''
573
573
WITH RECURSIVE crud_entries AS (
Original file line number Diff line number Diff line change @@ -280,15 +280,15 @@ void main() {
280
280
});
281
281
}
282
282
283
- await expectLater (powersync.nextCrudTransactions (), emitsDone);
283
+ await expectLater (powersync.getCrudTransactions (), emitsDone);
284
284
285
285
await createTransaction (5 );
286
286
await createTransaction (10 );
287
287
await createTransaction (15 );
288
288
289
289
CrudTransaction ? lastTransaction;
290
290
final batch = < CrudEntry > [];
291
- await for (final transaction in powersync.nextCrudTransactions ()) {
291
+ await for (final transaction in powersync.getCrudTransactions ()) {
292
292
batch.addAll (transaction.crud);
293
293
lastTransaction = transaction;
294
294
You can’t perform that action at this time.
0 commit comments