I've this code:
Stream<int> get fooStream async* {
barStream.listen((_) async* {
int baz = await getBaz();
yield baz; // Does not work
});
}
How can I return Stream<int> from another stream?
Note: If I use map to transform the stream, then I'll have to return Stream<Future<int>>, but I want to return Stream<int>. I also don't feel like using rxdart pacakge for this tiny thing.
CodePudding user response:
Use
asyncMap.barStream.asyncMap((e) => getBaz())Use
await forStream<int> get fooStream async* { await for (final item in barStream) { yield await getBaz(); } }
