Update charted to 0.4.8 and roll

packages/async/test/stream_splitter_test.dart

 // Copyright (c) 2015, 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.
 
 import 'dart:async';
 
 import 'package:async/async.dart';
 import 'package:test/test.dart';
 
 main() {
-  var controller;
+  StreamController<int> controller;
   var splitter;
   setUp(() {
     controller = new StreamController<int>();
     splitter = new StreamSplitter<int>(controller.stream);
   });
 
   test("a branch that's created before the stream starts to replay it",
       () async {
     var events = [];
     var branch = splitter.split();
@@ skipping 18 matching lines @@
   test("a branch replays error events as well as data events", () {
     var branch = splitter.split();
     splitter.close();
 
     controller.add(1);
     controller.addError("error");
     controller.add(3);
     controller.close();
 
     var count = 0;
-    branch.listen(expectAsync((value) {
-      expect(count, anyOf(0, 2));
-      expect(value, equals(count + 1));
-      count++;
-    }, count: 2), onError: expectAsync((error) {
+    branch.listen(
+        expectAsync1((value) {
+          expect(count, anyOf(0, 2));
+          expect(value, equals(count + 1));
+          count++;
+        }, count: 2), onError: expectAsync1((error) {
       expect(count, equals(1));
       expect(error, equals("error"));
       count++;
-    }), onDone: expectAsync(() {
+    }), onDone: expectAsync0(() {
       expect(count, equals(3));
     }));
   });
 
-  test("a branch that's created in the middle of a stream replays it", () async {
+  test("a branch that's created in the middle of a stream replays it",
+      () async {
     controller.add(1);
     controller.add(2);
     await flushMicrotasks();
 
     var branch = splitter.split();
     splitter.close();
 
     controller.add(3);
     controller.add(4);
     controller.close();
@@ skipping 23 matching lines @@
 
   // TODO(nweiz): Test that branches have the correct reified type once Dart
   // 1.11 is released. In 1.10, the stream exposed by a StreamController didn't
   // have a reified type.
 
   test("multiple branches each replay the stream", () async {
     var branch1 = splitter.split();
     controller.add(1);
     controller.add(2);
     await flushMicrotasks();
-    
+
     var branch2 = splitter.split();
     controller.add(3);
     controller.close();
     await flushMicrotasks();
-    
+
     var branch3 = splitter.split();
     splitter.close();
 
     expect(branch1.toList(), completion(equals([1, 2, 3])));
     expect(branch2.toList(), completion(equals([1, 2, 3])));
     expect(branch3.toList(), completion(equals([1, 2, 3])));
   });
 
   test("a branch doesn't close until the source stream closes", () async {
     var branch = splitter.split();
@@ skipping 77 matching lines @@
     var branch4 = splitter.split();
     splitter.close();
     await flushMicrotasks();
     expect(controller.isPaused, isTrue);
 
     branch4.listen(null);
     await flushMicrotasks();
     expect(controller.isPaused, isFalse);
   });
 
-  test("the source stream is canceled when it's closed after all branches have "
+  test(
+      "the source stream is canceled when it's closed after all branches have "
       "been canceled", () async {
     var branch1 = splitter.split();
     var branch2 = splitter.split();
     var branch3 = splitter.split();
 
     var subscription1 = branch1.listen(null);
     var subscription2 = branch2.listen(null);
     var subscription3 = branch3.listen(null);
 
     subscription1.cancel();
     await flushMicrotasks();
     expect(controller.hasListener, isTrue);
 
     subscription2.cancel();
     await flushMicrotasks();
     expect(controller.hasListener, isTrue);
 
     subscription3.cancel();
     await flushMicrotasks();
     expect(controller.hasListener, isTrue);
 
     splitter.close();
     expect(controller.hasListener, isFalse);
   });
 
-  test("the source stream is canceled when all branches are canceled after it "
+  test(
+      "the source stream is canceled when all branches are canceled after it "
       "has been closed", () async {
     var branch1 = splitter.split();
     var branch2 = splitter.split();
     var branch3 = splitter.split();
     splitter.close();
 
     var subscription1 = branch1.listen(null);
     var subscription2 = branch2.listen(null);
     var subscription3 = branch3.listen(null);
 
     subscription1.cancel();
     await flushMicrotasks();
     expect(controller.hasListener, isTrue);
 
     subscription2.cancel();
     await flushMicrotasks();
     expect(controller.hasListener, isTrue);
 
     subscription3.cancel();
     await flushMicrotasks();
     expect(controller.hasListener, isFalse);
   });
 
-  test("a splitter that's closed before any branches are added never listens "
+  test(
+      "a splitter that's closed before any branches are added never listens "
       "to the source stream", () {
     splitter.close();
 
     // This would throw an error if the stream had already been listened to.
     controller.stream.listen(null);
   });
 
-  test("splitFrom splits a source stream into the designated number of "
+  test(
+      "splitFrom splits a source stream into the designated number of "
       "branches", () {
     var branches = StreamSplitter.splitFrom(controller.stream, 5);
 
     controller.add(1);
     controller.add(2);
     controller.add(3);
     controller.close();
 
     expect(branches[0].toList(), completion(equals([1, 2, 3])));
     expect(branches[1].toList(), completion(equals([1, 2, 3])));
     expect(branches[2].toList(), completion(equals([1, 2, 3])));
     expect(branches[3].toList(), completion(equals([1, 2, 3])));
     expect(branches[4].toList(), completion(equals([1, 2, 3])));
   });
 }
 
 /// Wait for all microtasks to complete.
 Future flushMicrotasks() => new Future.delayed(Duration.ZERO);