Roll to pickup pool changes

packages/barback/lib/src/asset/asset_node.dart

 // 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 barback.asset.asset_node;
 
 import 'dart:async';
 
 import '../errors.dart';
 import '../graph/transform_node.dart';
@@ skipping 41 matching lines @@
   /// The callback to be called to notify this asset node's creator that the
   /// concrete asset should be generated.
   ///
   /// This is null for non-lazy asset nodes (see [AssetNodeController.lazy]).
   /// Once this is called, it's set to null and [this] is no longer considered
   /// lazy.
   Function _lazyCallback;
 
   /// Whether this node is lazy, meaning that [force] must be called to
   /// guarantee that it will eventually become available.
-  bool get isLazy => _lazyCallback != null ||
-      (_origin != null && _origin.isLazy);
+  bool get isLazy =>
+      _lazyCallback != null || (_origin != null && _origin.isLazy);
 
   /// A broadcast stream that emits an event whenever the node changes state.
   ///
   /// This stream is synchronous to ensure that when a source asset is modified
   /// or removed, the appropriate portion of the asset graph is dirtied before
   /// any [Barback.getAssetById] calls emit newly-incorrect values.
   Stream<AssetState> get onStateChange => _stateChangeController.stream;
 
   /// This is synchronous so that a source being updated will always be
   /// propagated through the build graph before anything that depends on it is
   /// requested.
   final _stateChangeController =
       new StreamController<AssetState>.broadcast(sync: true);
 
   /// Calls [callback] when the node's asset is available.
   ///
   /// If the asset is currently available, this calls [callback] synchronously
   /// to ensure that the asset is still available.
   ///
   /// The return value of [callback] is piped to the returned Future. If the
   /// asset is removed before becoming available, the returned future will throw
   /// an [AssetNotFoundException].
-  Future/*<T>*/ whenAvailable/*<T>*/(/*=T*/ callback(Asset asset)) {
+  Future<T> whenAvailable<T>(T callback(Asset asset)) {
     return _waitForState((state) => state.isAvailable || state.isRemoved,
         (state) {
       if (state.isRemoved) throw new AssetNotFoundException(id);
       return callback(asset);
     });
   }
 
   /// Calls [callback] when the node's asset is removed.
   ///
   /// If the asset is already removed when this is called, it calls [callback]
   /// synchronously.
   ///
   /// The return value of [callback] is piped to the returned Future.
   Future whenRemoved(callback()) =>
-    _waitForState((state) => state.isRemoved, (_) => callback());
+      _waitForState((state) => state.isRemoved, (_) => callback());
 
   /// Returns a [Future] that completes when [state] changes from its current
   /// value to any other value.
   ///
   /// The returned [Future] will contain the new state.
   Future<AssetState> whenStateChanges() {
     var startState = state;
     return _waitForState((state) => state != startState, (state) => state);
   }
 
   /// Calls [callback] as soon as the node is in a state that matches [test].
   ///
   /// [callback] is called synchronously if this is already in such a state.
   ///
   /// The return value of [callback] is piped to the returned Future.
-  Future/*<T>*/ _waitForState/*<T>*/(bool test(AssetState state),
-      /*=T*/ callback(AssetState state)) {
+  Future<T> _waitForState<T>(
+      bool test(AssetState state), T callback(AssetState state)) {
     if (test(state)) return new Future.sync(() => callback(state));
     return onStateChange.firstWhere(test).then((_) => callback(state));
   }
 
   AssetNode._(this.id, this._transform, this._origin)
       : _state = AssetState.RUNNING;
 
   AssetNode._available(Asset asset, this._transform, this._origin)
       : id = asset.id,
         _asset = asset,
@@ skipping 36 matching lines @@
   /// Creates a controller for a lazy node.
   ///
   /// For the most part, this node works like any other dirty node. However, the
   /// owner of its controller isn't expected to do the work to make it available
   /// as soon as possible like they would for a non-lazy node. Instead, when its
   /// value is needed, [callback] will fire to indicate that it should be made
   /// available as soon as possible.
   ///
   /// [callback] is guaranteed to only fire once.
   AssetNodeController.lazy(AssetId id, void callback(),
-          [TransformNode transform])
+      [TransformNode transform])
       : node = new AssetNode._lazy(id, transform, null, callback);
 
   /// Creates a controller for a node whose initial state matches the current
   /// state of [node].
   ///
   /// [AssetNode.origin] of the returned node will automatically be set to
   /// `node.origin`.
   ///
   /// If [node] is lazy, the returned node will also be lazy.
   AssetNodeController.from(AssetNode node)
@@ skipping 87 matching lines @@
 
   /// Whether this state is [AssetState.RUNNING].
   bool get isDirty => this == AssetState.RUNNING;
 
   final String name;
 
   const AssetState._(this.name);
 
   String toString() => name;
 }