update method

@visibleForTesting @protected FutureOr<T?> update(FutureOr<T> update(T old), { dynamic onError(Object e, StackTrace s)?, int slowlyMs = 100, Object? debounceTag, Object? throttleTag, dynamic ignoreSkipError = true, })

update if return value, will call put if return null, will not call put/putError onError if set null，will call putError if set function value, will not call putError, you can invoke putError manually slowlyMs if set <=0 value, will ignore debounce/throttleTag debounceTag enable debounce, require unique within the VM scope throttleTag enable throttle， require unique within the VM scope ignoreSkipError ref runCatching.ignoreSkipError

Implementation

@visibleForTesting
@protected
FutureOr<T?> update(
  FutureOr<T> Function(T old) update, {
  Function(Object e, StackTrace s)? onError,
  int slowlyMs = 100,
  Object? debounceTag,
  Object? throttleTag,
  ignoreSkipError = true,
}) async {
  if (slowlyMs > 0) {
    if (debounceTag != null) {
      /// debounce
      final deFunc = await slowly.debounce(
        debounceTag,
        update,
        duration: Duration(milliseconds: slowlyMs),
      );
      if (deFunc is! FutureOr<T> Function(T)) return null;
      update = deFunc;
    } else if (throttleTag != null) {
      /// throttle
      final thFunc = slowly.throttle(
        throttleTag,
        update,
        duration: Duration(milliseconds: slowlyMs),
      );
      if (thFunc is! FutureOr<T> Function(T)) return null;
      update = thFunc;
    }
  }
  return await runCatching<T>(
    () => update(value),
    onSuccess: (r) => put(r),
    onFailure: (e, s) => (onError ?? putError).call(e, s),
    ignoreSkipError: ignoreSkipError,
  );
}