blob: d5c398c8fdce2e3edc8749ade62e7c5f73e7d48a [file] [log] [blame]
// Copyright (c) 2024, the Dart project authors. Please see the AUTHORS file
// for details. All rights reserved. Use of this source code is governed by a
// BSD-style license that can be found in the LICENSE file.
import "package:async_helper/async_helper.dart";
import "package:expect/expect.dart";
Stream<String> stream() async* {
yield 'a';
yield 'b';
}
Stream<String> expandedStream() async* {
final expanded = stream().asyncExpand((s) async* {
yield 'before';
yield s;
yield 'after';
});
yield* expanded;
}
test() async {
Expect.listEquals(['before', 'a', 'after', 'before', 'b', 'after'],
await expandedStream().toList());
}
void main() {
asyncStart();
test().then((_) => asyncEnd());
}