| 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.graph.group_runner; |   5 library barback.graph.group_runner; | 
|   6  |   6  | 
|   7 import 'dart:async'; |   7 import 'dart:async'; | 
|   8  |   8  | 
|   9 import '../asset/asset_node.dart'; |   9 import '../asset/asset_node.dart'; | 
|  10 import '../log.dart'; |  10 import '../log.dart'; | 
| (...skipping 17 matching lines...) Expand all  Loading... | 
|  28  |  28  | 
|  29   /// How far along [this] is in processing its assets. |  29   /// How far along [this] is in processing its assets. | 
|  30   NodeStatus get status { |  30   NodeStatus get status { | 
|  31     // Just check the last phase, since it will check all the previous phases |  31     // Just check the last phase, since it will check all the previous phases | 
|  32     // itself. |  32     // itself. | 
|  33     return _phases.last.status; |  33     return _phases.last.status; | 
|  34   } |  34   } | 
|  35  |  35  | 
|  36   /// A stream that emits an event every time the group's status changes. |  36   /// A stream that emits an event every time the group's status changes. | 
|  37   Stream<NodeStatus> get onStatusChange => _onStatusChange; |  37   Stream<NodeStatus> get onStatusChange => _onStatusChange; | 
|  38   Stream _onStatusChange; |  38   Stream<NodeStatus> _onStatusChange; | 
|  39  |  39  | 
|  40   /// A stream that emits any new assets emitted by [this]. |  40   /// A stream that emits any new assets emitted by [this]. | 
|  41   /// |  41   /// | 
|  42   /// Assets are emitted synchronously to ensure that any changes are thoroughly |  42   /// Assets are emitted synchronously to ensure that any changes are thoroughly | 
|  43   /// propagated as soon as they occur. |  43   /// propagated as soon as they occur. | 
|  44   Stream<AssetNode> get onAsset => _onAsset; |  44   Stream<AssetNode> get onAsset => _onAsset; | 
|  45   Stream<AssetNode> _onAsset; |  45   Stream<AssetNode> _onAsset; | 
|  46  |  46  | 
|  47   /// A stream that emits an event whenever any transforms in this group logs |  47   /// A stream that emits an event whenever any transforms in this group logs | 
|  48   /// an entry. |  48   /// an entry. | 
| (...skipping 31 matching lines...) Expand 10 before | Expand all | Expand 10 after  Loading... | 
|  80   /// Removes this group and all sub-phases within it. |  80   /// Removes this group and all sub-phases within it. | 
|  81   void remove() { |  81   void remove() { | 
|  82     _onLogPool.close(); |  82     _onLogPool.close(); | 
|  83     for (var phase in _phases) { |  83     for (var phase in _phases) { | 
|  84       phase.remove(); |  84       phase.remove(); | 
|  85     } |  85     } | 
|  86   } |  86   } | 
|  87  |  87  | 
|  88   String toString() => "group in phase $_location for $_group"; |  88   String toString() => "group in phase $_location for $_group"; | 
|  89 } |  89 } | 
| OLD | NEW |