Index: packages/async/test/stream_splitter_test.dart |
diff --git a/packages/async/test/stream_splitter_test.dart b/packages/async/test/stream_splitter_test.dart |
index ffd0c87afb2899a0f6decf1ac804e93dcc67e447..68a6b74c0cd25c04c57bcfdf5f40a181e2f81b1f 100644 |
--- a/packages/async/test/stream_splitter_test.dart |
+++ b/packages/async/test/stream_splitter_test.dart |
@@ -8,7 +8,7 @@ import 'package:async/async.dart'; |
import 'package:test/test.dart'; |
main() { |
- var controller; |
+ StreamController<int> controller; |
var splitter; |
setUp(() { |
controller = new StreamController<int>(); |
@@ -47,20 +47,22 @@ main() { |
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(); |
@@ -104,12 +106,12 @@ main() { |
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(); |
@@ -207,7 +209,8 @@ main() { |
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(); |
@@ -233,7 +236,8 @@ main() { |
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(); |
@@ -257,7 +261,8 @@ main() { |
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(); |
@@ -265,7 +270,8 @@ main() { |
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); |