(element: Cursor<T>)
| 94 | return result; |
| 95 | |
| 96 | async function awaitNext(element: Cursor<T>): Promise<Cursor<T>> { |
| 97 | element.result = undefined; // drop the previous result before awaiting the next |
| 98 | element.result = await element.iterator.next(); |
| 99 | return element; |
| 100 | } |
| 101 | |
| 102 | async function* combiner(iterables: Some<T>[]) { |
| 103 | iterables.forEach((iterable, index) => iterators.set(index, awaitNext({ identity: index, iterator: asyncOf(iterable)[Symbol.asyncIterator]() }))); |
no test coverage detected