Roll to pickup pool changes

packages/barback/test/stream_replayer_test.dart

Index: packages/barback/test/stream_replayer_test.dart
diff --git a/packages/barback/test/stream_replayer_test.dart b/packages/barback/test/stream_replayer_test.dart
index 802db14f663c9c3921163d75e5b245a8eae82515..a0b6f1a2a85f3f7480655d724d0088352561b640 100644
--- a/packages/barback/test/stream_replayer_test.dart
+++ b/packages/barback/test/stream_replayer_test.dart
@@ -15,7 +15,8 @@ import 'utils.dart';
 main() {
   initConfig();
 
-  test("a replay that's retrieved before the stream is finished replays the "
+  test(
+      "a replay that's retrieved before the stream is finished replays the "
       "stream", () {
     var controller = new StreamController<int>();
     var replay = new StreamReplayer<int>(controller.stream).getReplay();
@@ -28,7 +29,8 @@ main() {
     expect(replay.toList(), completion(equals([1, 2, 3])));
   });
 
-  test("a replay that's retrieved after the stream is finished replays the "
+  test(
+      "a replay that's retrieved after the stream is finished replays the "
       "stream", () {
     var controller = new StreamController<int>();
     var replayer = new StreamReplayer<int>(controller.stream);
@@ -68,13 +70,15 @@ main() {
     controller.add(2);
     controller.add(3);
 
-    expect(pumpEventQueue().then((_) {
-      expect(isClosed, isFalse);
-      controller.close();
-      return pumpEventQueue();
-    }).then((_) {
-      expect(isClosed, isTrue);
-    }), completes);
+    expect(
+        pumpEventQueue().then((_) {
+          expect(isClosed, isFalse);
+          controller.close();
+          return pumpEventQueue();
+        }).then((_) {
+          expect(isClosed, isTrue);
+        }),
+        completes);
   });
 
   test("the wrapped stream isn't opened if there are no replays", () {
@@ -82,7 +86,7 @@ main() {
     var controller = new StreamController<int>(onListen: () {
       isOpened = true;
     });
-    var replayer = new StreamReplayer<int>(controller.stream);
+    new StreamReplayer<int>(controller.stream);
 
     expect(pumpEventQueue().then((_) => isOpened), completion(isFalse));
   });