Stream<Future<Iterable<V>>> awaitEach() { return this.map((iterables) async { return await Future.wait(iterables, eagerError: true); }); }