88 lines
1.6 KiB
Dart
88 lines
1.6 KiB
Dart
import 'dart:async';
|
|
|
|
class Debouncer {
|
|
final Map<dynamic, Timer?> _operations = {};
|
|
|
|
call(
|
|
dynamic tag,
|
|
Function func, {
|
|
List<dynamic>? args,
|
|
Duration duration = const Duration(milliseconds: 600),
|
|
}) {
|
|
final timer = _operations[tag];
|
|
if (timer != null) {
|
|
timer.cancel();
|
|
}
|
|
_operations[tag] = Timer(
|
|
duration,
|
|
() {
|
|
_operations[tag]?.cancel();
|
|
_operations.remove(tag);
|
|
Function.apply(
|
|
func,
|
|
args,
|
|
);
|
|
},
|
|
);
|
|
}
|
|
|
|
cancel(dynamic tag) {
|
|
_operations[tag]?.cancel();
|
|
_operations[tag] = null;
|
|
}
|
|
}
|
|
|
|
class Throttler {
|
|
final Map<dynamic, Timer?> _operations = {};
|
|
|
|
call(
|
|
dynamic tag,
|
|
Function func, {
|
|
List<dynamic>? args,
|
|
Duration duration = const Duration(milliseconds: 600),
|
|
}) {
|
|
final timer = _operations[tag];
|
|
if (timer != null) {
|
|
return true;
|
|
}
|
|
_operations[tag] = Timer(
|
|
duration,
|
|
() {
|
|
_operations[tag]?.cancel();
|
|
_operations.remove(tag);
|
|
Function.apply(
|
|
func,
|
|
args,
|
|
);
|
|
},
|
|
);
|
|
return false;
|
|
}
|
|
|
|
cancel(dynamic tag) {
|
|
_operations[tag]?.cancel();
|
|
_operations[tag] = null;
|
|
}
|
|
}
|
|
|
|
Future<T> retry<T>({
|
|
required Future<T> Function() task,
|
|
int maxAttempts = 3,
|
|
required bool Function(T res) retryIf,
|
|
Duration delay = Duration.zero,
|
|
}) async {
|
|
int attempts = 0;
|
|
while (attempts < maxAttempts) {
|
|
final res = await task();
|
|
if (!retryIf(res) || attempts >= maxAttempts) {
|
|
return res;
|
|
}
|
|
attempts++;
|
|
}
|
|
throw "unknown error";
|
|
}
|
|
|
|
final debouncer = Debouncer();
|
|
|
|
final throttler = Throttler();
|