blob: 88c0fa386bdb8f92d6af478087fa26d6819a53ea [file] [log] [blame]
// Copyright (c) 2013, 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.
library test_utils;
import 'dart:async';
import 'package:scheduled_test/scheduled_test.dart';
import 'package:scheduled_test/src/utils.dart';
import 'package:scheduled_test/src/mock_clock.dart' as mock_clock;
import 'metatest.dart';
export 'package:scheduled_test/src/utils.dart';
/// Wraps [input] to provide a timeout. If [input] completes before
/// [milliseconds] have passed, then the return value completes in the same way.
/// However, if [milliseconds] pass before [input] has completed, [onTimeout] is
/// run and its result is passed to [input] (with chaining, if it returns a
/// [Future]).
/// Note that timing out will not cancel the asynchronous operation behind
/// [input].
Future timeout(Future input, int milliseconds, onTimeout()) {
var completer = new Completer();
var timer = new Timer(new Duration(milliseconds: milliseconds), () {
chainToCompleter(new Future.sync(onTimeout), completer);
input.then((value) {
if (completer.isCompleted) return;
}).catchError((error) {
if (completer.isCompleted) return;
return completer.future;
/// Returns a [Future] that will complete in [milliseconds].
Future sleep(int milliseconds) {
var completer = new Completer();
mock_clock.newTimer(new Duration(milliseconds: milliseconds), () {
return completer.future;
/// Sets up a timeout for every metatest in this file.
void setUpTimeout() {
metaSetUp(() {
// TODO(nweiz): We used to only increase the timeout to 10s for the Windows
// bots, but the Linux and Mac bots have started taking upwards of 5s when
// running pumpEventQueue, so we're increasing the timeout across the board
// (see issue 9248).
currentSchedule.timeout = new Duration(seconds: 10);