Skip to content

Commit 3b73435

Browse files
committed
Start integrating Rust extension
1 parent df5665a commit 3b73435

File tree

2 files changed

+2
-1
lines changed

2 files changed

+2
-1
lines changed

packages/powersync_core/lib/src/sync/mutable_sync_status.dart

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,8 +1,8 @@
11
import 'dart:async';
22

33
import 'package:collection/collection.dart';
4+
import 'package:powersync_core/src/sync/instruction.dart';
45

5-
import 'instruction.dart';
66
import 'sync_status.dart';
77
import 'bucket_storage.dart';
88
import 'protocol.dart';

packages/powersync_core/lib/src/sync/streaming_sync.dart

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -248,6 +248,7 @@ class StreamingSyncImplementation implements StreamingSync {
248248
}
249249

250250
assert(identical(_activeCrudUpload, completer));
251+
_nonLineSyncEvents.add(const UploadCompleted());
251252
_activeCrudUpload = null;
252253
completer.complete();
253254
});

0 commit comments

Comments
 (0)