Chromium Code Reviews| OLD | NEW |
|---|---|
| 1 // Copyright (c) 2011, the Dart project authors. Please see the AUTHORS file | 1 // Copyright (c) 2011, the Dart project authors. Please see the AUTHORS file |
| 2 // for details. All rights reserved. Use of this source code is governed by a | 2 // for details. All rights reserved. Use of this source code is governed by a |
| 3 // BSD-style license that can be found in the LICENSE file. | 3 // BSD-style license that can be found in the LICENSE file. |
| 4 | 4 |
| 5 // Dart core library. | 5 // Dart core library. |
| 6 | 6 |
| 7 | 7 |
| 8 /** | 8 /** |
| 9 * A Future is used to obtain a value sometime in the | 9 * A Future is used to obtain a value sometime in the |
| 10 * future. | 10 * future. |
| (...skipping 93 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 104 /** | 104 /** |
| 105 * Called when value is available. | 105 * Called when value is available. |
| 106 */ | 106 */ |
| 107 void complete(T value); | 107 void complete(T value); |
| 108 | 108 |
| 109 /** | 109 /** |
| 110 * Called if an exception occured while trying to produce value. | 110 * Called if an exception occured while trying to produce value. |
| 111 */ | 111 */ |
| 112 void completeException(Object exception); | 112 void completeException(Object exception); |
| 113 } | 113 } |
| 114 | |
| 115 | |
| 116 /** | |
| 117 * This class is for utility functions that operate on Futures (for | |
| 118 * example, waiting for a collectin of Futures to complete). | |
|
Siggi Cherem (dart-lang)
2011/11/04 17:35:28
collectin -> collection
Futures -> futures
Ben Laurie (Google)
2011/11/04 17:54:46
or [Future]s
| |
| 119 */ | |
| 120 class Futures { | |
| 121 | |
| 122 /** | |
| 123 * Returns a future which will complete once all the futures in a | |
|
Siggi Cherem (dart-lang)
2011/11/04 17:35:28
a future -> a [Future]
| |
| 124 * list are complete. (The value of the returned future will | |
| 125 * be a list of all the values that were produced.) | |
| 126 */ | |
| 127 static Future<List> wait(List<Future> futures) { | |
| 128 Completer completer = new Completer<List>(); | |
| 129 int remaining = futures.length; | |
| 130 List<Object> values = new List(futures.length); | |
| 131 | |
| 132 // As each future completes, put its value into the corresponding | |
| 133 // position in the list of values. | |
| 134 for (int i = 0; i < futures.length; i++) { | |
| 135 // TODO(mattsh) - remove this after bug | |
| 136 // http://code.google.com/p/dart/issues/detail?id=333 is fixed. | |
| 137 int pos = i; | |
| 138 futures[pos].then((Object value) { | |
| 139 values[pos] = value; | |
| 140 if (--remaining == 0) { | |
| 141 completer.complete(values); | |
| 142 } | |
| 143 }); | |
| 144 } | |
| 145 return completer.future; | |
| 146 } | |
| 147 } | |
| 148 | |
| OLD | NEW |