blob: 3287c6aafacc4cef87f72f496d5ebaa384d667e6 [file] [log] [blame]
/*
* Copyright (c) 2011, 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.
*/
/**
* @assertion void complete([T value])
* Completes future with the supplied values.
* The value must be either a value of type T or a future of type Future<T>.
* If the value is itself a future, the completer will wait for that future to
* complete, and complete with the same result, whether it is a success or an
* error.
* All listeners on the future are informed about the value.
* @description Checks that all listeners on the future are informed.
* @author kaigorodov
*/
import "dart:async";
import "../../../Utils/expect.dart";
int N = 10;
const v = 99;
List<Future<dynamic>> futures = [];
int count = 0;
main() {
var completer = new Completer();
var future = completer.future;
for (int k = 0; k < N; k++) {
asyncStart();
futures.add(future.then((fValue) {
Expect.equals(v, fValue);
++count;
asyncEnd();
}));
}
Future.wait(futures).whenComplete(() => Expect.equals(N, count));
completer.complete(v);
}