Function pump

client/js/src/internal/asyncIteratorMap.ts:32–55

()

    let inputError: unknown | undefined;

    const executing = new Set<Promise<void>>();
    const results: Array<Promise<O>> = [];

    const pump = async () => {
        let next;
        try {
            next = await inputIterator.next();
        } catch (error) {
            hasInputError = true;
            inputError = error;
            done = true;
            return;
        }

        if (next.done) {
            done = true;
            return;
        }

        const promise = mapper(next.value)
            .then((result) => {
                results.push(Promise.resolve(result));
            })
            .catch((error) => {
                results.push(Promise.reject(error));
            });
        executing.add(promise);