blob: 256740dff095b673df838898a9b1bec3f4766434 [file] [log] [blame]
// Copyright (c) 2016, the Dart project authors. Please see the AUTHORS file
// for details. All rights reserved. Use of this source code is governed by a
// BSD-style license that can be found in the LICENSE file.
// @dart = 2.9
import 'dart:async';
import 'dart:io';
import "package:expect/expect.dart";
int lastRetryId = 0;
Future retry(Future fun(), {int maxCount: 10}) async {
final int id = lastRetryId++;
for (int i = 0; i < maxCount; i++) {
try {
// If there is no exception this will simply return, otherwise we keep
// trying.
return await fun();
} catch (e, stack) {
print("Failed to execute test closure (retry id: ${id}) in attempt $i "
"(${maxCount - i} retries left).");
print("Exception: ${e}");
print("Stacktrace: ${stack}");
}
}
return await fun();
}
Future throws(Function f, bool check(Object exception)) async {
try {
await f();
} catch (e) {
if (!check(e)) {
Expect.fail('Unexpected: $e');
}
return;
}
Expect.fail('Did not throw');
}
// Create a temporary directory and delete it when the test function exits.
Future withTempDir(String prefix, Future<void> test(Directory dir)) async {
final tempDir = Directory.systemTemp.createTempSync(prefix);
try {
await runZonedGuarded(() => test(tempDir), (e, st) {
try {
tempDir.deleteSync(recursive: true);
} catch (_) {
// ignore errors
}
throw e;
});
} finally {
try {
tempDir.deleteSync(recursive: true);
} catch (_) {
// ignore errors
}
}
}