(generators: AsyncGenerator<T>[])
| 1 | import { asyncIteratorRace } from './asyncIteratorRace'; |
| 2 | |
| 3 | async function* createInputIterator<T>(generators: AsyncGenerator<T>[]): AsyncGenerator<AsyncGenerator<T>> { |
| 4 | for (const generator of generators) { |
| 5 | yield generator; |
| 6 | } |
| 7 | } |
| 8 | |
| 9 | async function* createAsyncGenerator<T>(values: T[], delay: number = 0): AsyncGenerator<T> { |
| 10 | for (const value of values) { |
no outgoing calls
no test coverage detected