Chromium Code Reviews| OLD | NEW |
|---|---|
| 1 // Copyright (c) 2013, the Dart project authors. Please see the AUTHORS file | 1 // Copyright (c) 2013, 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 library barback.phase; | 5 library barback.phase; |
| 6 | 6 |
| 7 import 'dart:async'; | 7 import 'dart:async'; |
| 8 import 'dart:collection'; | 8 import 'dart:collection'; |
| 9 | 9 |
| 10 import 'asset.dart'; | 10 import 'asset.dart'; |
| 11 import 'asset_cascade.dart'; | 11 import 'asset_cascade.dart'; |
| 12 import 'asset_id.dart'; | 12 import 'asset_id.dart'; |
| 13 import 'asset_node.dart'; | 13 import 'asset_node.dart'; |
| 14 import 'asset_set.dart'; | |
| 15 import 'errors.dart'; | 14 import 'errors.dart'; |
| 16 import 'stream_pool.dart'; | 15 import 'stream_pool.dart'; |
| 17 import 'transform_node.dart'; | 16 import 'transform_node.dart'; |
| 18 import 'transformer.dart'; | 17 import 'transformer.dart'; |
| 19 import 'utils.dart'; | 18 import 'utils.dart'; |
| 20 | 19 |
| 21 /// One phase in the ordered series of transformations in an [AssetCascade]. | 20 /// One phase in the ordered series of transformations in an [AssetCascade]. |
| 22 /// | 21 /// |
| 23 /// Each phase can access outputs from previous phases and can in turn pass | 22 /// Each phase can access outputs from previous phases and can in turn pass |
| 24 /// outputs to later phases. Phases are processed strictly serially. All | 23 /// outputs to later phases. Phases are processed strictly serially. All |
| (...skipping 291 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 316 } | 315 } |
| 317 | 316 |
| 318 Future _waitForInputs() { | 317 Future _waitForInputs() { |
| 319 if (_adjustTransformersFutures.isEmpty) return new Future.value(); | 318 if (_adjustTransformersFutures.isEmpty) return new Future.value(); |
| 320 return Future.wait(_adjustTransformersFutures.values) | 319 return Future.wait(_adjustTransformersFutures.values) |
| 321 .then((_) => _waitForInputs()); | 320 .then((_) => _waitForInputs()); |
| 322 } | 321 } |
| 323 | 322 |
| 324 /// Applies all currently wired up and dirty transforms. | 323 /// Applies all currently wired up and dirty transforms. |
| 325 Future _processTransforms() { | 324 Future _processTransforms() { |
| 326 if (_next == null) return; | 325 if (_next == null) return new Future.value(); |
|
Bob Nystrom
2013/08/19 23:03:55
This will go away when you sync to latest code, I
| |
| 327 | 326 |
| 328 var newPassThroughs = _passThroughControllers.values | 327 var newPassThroughs = _passThroughControllers.values |
| 329 .map((controller) => controller.node) | 328 .map((controller) => controller.node) |
| 330 .where((output) { | 329 .where((output) { |
| 331 return !_outputs.containsKey(output.id) || | 330 return !_outputs.containsKey(output.id) || |
| 332 !_outputs[output.id].contains(output); | 331 !_outputs[output.id].contains(output); |
| 333 }).toSet(); | 332 }).toSet(); |
| 334 | 333 |
| 335 // Convert this to a list so we can safely modify _transforms while | 334 // Convert this to a list so we can safely modify _transforms while |
| 336 // iterating over it. | 335 // iterating over it. |
| (...skipping 87 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 424 // Pump the event queue to ensure that the removal of the input triggers | 423 // Pump the event queue to ensure that the removal of the input triggers |
| 425 // a new build to which we can attach the error. | 424 // a new build to which we can attach the error. |
| 426 newFuture(() => cascade.reportError(new AssetCollisionException( | 425 newFuture(() => cascade.reportError(new AssetCollisionException( |
| 427 assets.where((asset) => asset.transform != null) | 426 assets.where((asset) => asset.transform != null) |
| 428 .map((asset) => asset.transform.info), | 427 .map((asset) => asset.transform.info), |
| 429 output.id))); | 428 output.id))); |
| 430 } | 429 } |
| 431 }); | 430 }); |
| 432 } | 431 } |
| 433 } | 432 } |
| OLD | NEW |