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)); |
}); |