mirror of
https://github.com/immich-app/immich.git
synced 2024-12-29 11:24:37 +02:00
cae37657e9
* fix(mobile): allow syncing duplicate local IDs * enable to run isar unit tests on CI * serialize sync operations, add pull to refresh on timeline --------- Co-authored-by: Fynn Petersen-Frey <zoodyy@users.noreply.github.com>
22 lines
624 B
Dart
22 lines
624 B
Dart
import 'dart:async';
|
|
|
|
/// Async mutex to guarantee actions are performed sequentially and do not interleave
|
|
class AsyncMutex {
|
|
Future _running = Future.value(null);
|
|
int _enqueued = 0;
|
|
|
|
get enqueued => _enqueued;
|
|
|
|
/// Execute [operation] exclusively, after any currently running operations.
|
|
/// Returns a [Future] with the result of the [operation].
|
|
Future<T> run<T>(Future<T> Function() operation) {
|
|
final completer = Completer<T>();
|
|
_enqueued++;
|
|
_running.whenComplete(() {
|
|
_enqueued--;
|
|
completer.complete(Future<T>.sync(operation));
|
|
});
|
|
return _running = completer.future;
|
|
}
|
|
}
|