Skip to content
Merged
Changes from 1 commit
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
8 changes: 6 additions & 2 deletions packages/powersync/lib/src/abort_controller.dart
Original file line number Diff line number Diff line change
Expand Up @@ -17,14 +17,18 @@ class AbortController {
/// Abort, and wait until aborting is complete.
Future<void> abort() async {
aborted = true;
_abortRequested.complete();
if (!_abortRequested.isCompleted) {
_abortRequested.complete();
}

await _abortCompleter.future;
}

/// Signal that an abort has completed.
void completeAbort() {
_abortCompleter.complete();
if (!_abortCompleter.isCompleted) {
_abortCompleter.complete();
}
}

/// Signal that an abort has failed.
Expand Down