| 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) {
|
|
|