Index: tests/lib/async/stream_group_by_test.dart |
diff --git a/tests/lib/async/stream_group_by_test.dart b/tests/lib/async/stream_group_by_test.dart |
index edba9e089a9e49947a8cfb58ee7bedbaca6c731e..2abbf2647a4c23c0a330d173686dfc91aa2e3b85 100644 |
--- a/tests/lib/async/stream_group_by_test.dart |
+++ b/tests/lib/async/stream_group_by_test.dart |
@@ -18,7 +18,7 @@ void main() { |
test("splits", () async { |
var grouped = stringStream.groupBy<int>(len); |
var byLength = <int, Future<List<String>>>{}; |
- await for (StreamGroup<int, String> group in grouped) { |
+ await for (GroupedEvents<int, String> group in grouped) { |
byLength[group.key] = group.values.toList(); |
} |
Expect.listEquals([1, 2, 4, 3], byLength.keys.toList()); |
@@ -31,7 +31,7 @@ void main() { |
test("empty", () async { |
var grouped = emptyStream.groupBy<int>(len); |
var byLength = <int, Future<List<String>>>{}; |
- await for (StreamGroup<int, String> group in grouped) { |
+ await for (GroupedEvents<int, String> group in grouped) { |
byLength[group.key] = group.values.toList(); |
} |
Expect.isTrue(byLength.isEmpty); |
@@ -40,7 +40,7 @@ void main() { |
test("single group", () async { |
var grouped = repeatStream(5, "x").groupBy<int>(len); |
var byLength = <int, Future<List<String>>>{}; |
- await for (StreamGroup<int, String> group in grouped) { |
+ await for (GroupedEvents<int, String> group in grouped) { |
byLength[group.key] = group.values.toList(); |
} |
Expect.listEquals([1], byLength.keys.toList()); |
@@ -52,7 +52,7 @@ void main() { |
var byLength = <int, Future<List<String>>>{}; |
bool caught = false; |
try { |
- await for (StreamGroup<int, String> group in grouped) { |
+ await for (GroupedEvents<int, String> group in grouped) { |
byLength[group.key] = group.values.toList(); |
} |
} catch (e) { |