Skip to content

Commit 6ec3d72

Browse files
committed
Remove immediate unsubscribe options
1 parent c87db08 commit 6ec3d72

File tree

2 files changed

+3
-6
lines changed

2 files changed

+3
-6
lines changed

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

Lines changed: 2 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -217,13 +217,11 @@ final class ConnectionManager {
217217
Future<void> unsubscribe({
218218
required String stream,
219219
required Object? parameters,
220-
required bool immediate,
221220
}) async {
222221
await _subscriptionsCommand({
223222
'unsubscribe': {
224223
'stream': stream,
225224
'params': parameters,
226-
'immediate': immediate,
227225
},
228226
});
229227
}
@@ -334,9 +332,8 @@ final class _SyncStreamSubscription implements SyncStreamSubscription {
334332
});
335333

336334
@override
337-
Future<void> unsubscribe({bool immediately = false}) async {
338-
await _connections.unsubscribe(
339-
stream: name, parameters: parameters, immediate: immediately);
335+
Future<void> unsubscribe() async {
336+
await _connections.unsubscribe(stream: name, parameters: parameters);
340337
}
341338

342339
@override

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -83,7 +83,7 @@ abstract interface class SyncStreamSubscription
8383
///
8484
/// The subscription may still be included for a while, until the client
8585
/// reconnects and receives new snapshots from the sync service.
86-
Future<void> unsubscribe({bool immediately = false});
86+
Future<void> unsubscribe();
8787
}
8888

8989
/// An `ActiveStreamSubscription` as part of the sync status in Rust.

0 commit comments

Comments
 (0)