enqueue<T> method

Future<T> enqueue<T>(
  1. Future<T> taskBuilder(), {
  2. Duration autoComplete = const Duration(seconds: 5),
})

Implementation

Future<T> enqueue<T>(
  Future<T> Function() taskBuilder, {
  Duration autoComplete = const Duration(seconds: 5),
}) {
  final uuid = Uuid().v4();
  add(uuid, autoComplete: autoComplete);
  return taskBuilder()
      .catchError(catchError)
      .whenComplete(() => complete(uuid));
}