ValueStream<Future<Iterable<R>>> thenMapEach<R>(R mapper(X input)) { return this.map((item) async { final resolved = await item; return resolved.map((each) => mapper(each)); }); }