Roll to pickup pool changes

packages/barback/lib/src/transformer/aggregate_transform.dart

 // Copyright (c) 2014, 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.transformer.aggregate_transform;
 
 import 'dart:async';
 import 'dart:convert';
 
 import 'package:async/async.dart';
@@ skipping 63 matching lines @@
   ///
   /// This is equivalent to calling [getInput] followed by [Asset.readAsString].
   ///
   /// If the asset was created from a [String] the original string is always
   /// returned and [encoding] is ignored. Otherwise, the binary data of the
   /// asset is decoded using [encoding], which defaults to [UTF8].
   ///
   /// If an input with [id] cannot be found, throws an [AssetNotFoundException].
   Future<String> readInputAsString(AssetId id, {Encoding encoding}) {
     if (encoding == null) encoding = UTF8;
-    return getInput(id).then/*<Future<String>>*/(
+    return getInput(id).then<Future<String>>(
         (input) => input.readAsString(encoding: encoding));
   }
 
   /// A convenience method to the contents of the input with [id].
   ///
   /// This is equivalent to calling [getInput] followed by [Asset.read].
   ///
   /// If the asset was created from a [String], this returns its UTF-8 encoding.
   ///
   /// If an input with [id] cannot be found, throws an [AssetNotFoundException].
   Stream<List<int>> readInput(AssetId id) =>
       futureStream(getInput(id).then((input) => input.read()));
 
   /// A convenience method to return whether or not an asset exists.
   ///
   /// This is equivalent to calling [getInput] and catching an
   /// [AssetNotFoundException].
   Future<bool> hasInput(AssetId id) {
-    return DelegatingFuture.typed(
-        getInput(id).then((_) => true).catchError((error) {
+    return DelegatingFuture
+        .typed(getInput(id).then((_) => true).catchError((error) {
       if (error is AssetNotFoundException && error.id == id) return false;
       throw error;
     }));
   }
 
   /// Stores [output] as an output created by this transformation.
   ///
   /// A transformation can output as many assets as it wants.
   void addOutput(Asset output) {
     // TODO(rnystrom): This should immediately throw if an output with that ID
@@ skipping 24 matching lines @@
       : transform = new AggregateTransform._(node);
 
   /// Adds a primary input asset to the [AggregateTransform.primaryInputs]
   /// stream.
   void addInput(Asset input) {
     transform._emittedPrimaryInputs.add(input);
     transform._inputController.add(input);
   }
 
   /// Returns whether an input with the given [id] was added via [addInput].
-  bool addedId(AssetId id) =>
-      transform._emittedPrimaryInputs.containsId(id);
+  bool addedId(AssetId id) => transform._emittedPrimaryInputs.containsId(id);
 
   void done() {
     transform._inputController.close();
   }
 }