Skip to content

Commit d104fd2

Browse files
committed
Revert intended changes
1 parent 814bade commit d104fd2

File tree

4 files changed

+6
-2
lines changed

4 files changed

+6
-2
lines changed

packages/powersync_core/lib/src/database/powersync_db_mixin.dart

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -292,6 +292,8 @@ mixin PowerSyncDatabaseMixin implements SqliteConnection {
292292
final resolvedOptions = ResolvedSyncOptions.resolve(
293293
options,
294294
crudThrottleTime: crudThrottleTime,
295+
// ignore: deprecated_member_use_from_same_package
296+
retryDelay: retryDelay,
295297
params: params,
296298
);
297299

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';
54

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

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

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -36,6 +36,7 @@ final class SyncOptions {
3636

3737
SyncOptions _copyWith({
3838
Duration? crudThrottleTime,
39+
Duration? retryDelay,
3940
Map<String, dynamic>? params,
4041
}) {
4142
return SyncOptions(
@@ -78,10 +79,12 @@ extension type ResolvedSyncOptions(SyncOptions source) {
7879
factory ResolvedSyncOptions.resolve(
7980
SyncOptions? source, {
8081
Duration? crudThrottleTime,
82+
Duration? retryDelay,
8183
Map<String, dynamic>? params,
8284
}) {
8385
return ResolvedSyncOptions((source ?? SyncOptions())._copyWith(
8486
crudThrottleTime: crudThrottleTime,
87+
retryDelay: retryDelay,
8588
params: params,
8689
));
8790
}

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

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -245,7 +245,6 @@ class StreamingSyncImplementation implements StreamingSync {
245245
}
246246

247247
assert(identical(_activeCrudUpload, completer));
248-
_nonLineSyncEvents.add(const UploadCompleted());
249248
_activeCrudUpload = null;
250249
completer.complete();
251250
});

0 commit comments

Comments
 (0)