convertHandler<T extends Object> static method

TTaskHandler<T> convertHandler<T extends Object>(
  1. @sendable FutureOr<T?> handler(
    1. T? prev,
    2. Err<Object>? err
    )
)

Implementation

static TTaskHandler<T> convertHandler<T extends Object>(
  @sendable FutureOr<T?> Function(T? prev, Err? err) handler,
) {
  return (prev) {
    return Resolvable(() {
      final prevValue = prev.orNull()?.orNull();
      final err = prev.err().orNull();
      final nextValue = handler(prevValue, err);
      if (nextValue is Future<T?>) {
        return nextValue.then(Option.from);
      }
      return Option.from(nextValue);
    });
  };
}