@reactivex/ix-esnext-esm/asynciterable/zip.js

import { AsyncIterableX } from './asynciterablex';
import { identityAsync } from '../internal/identity';
import { returnAsyncIterator } from '../internal/returniterator';
export class ZipAsyncIterable extends AsyncIterableX {
    constructor(sources, fn) {
        super();
        this._sources = sources;
        this._fn = fn;
    }
    async *[Symbol.asyncIterator]() {
        const fn = this._fn;
        const sourcesLength = this._sources.length;
        const its = this._sources.map(x => x[Symbol.asyncIterator]());
        do {
            const values = new Array(sourcesLength);
            for (let i = -1; ++i < sourcesLength;) {
                const result = await its[i].next();
                if (result.done) {
                    await Promise.all(its.map(returnAsyncIterator));
                    return undefined;
                }
                values[i] = result.value;
            }
            yield await fn(values);
        } while (1);
    }
}
/* tslint:enable:max-line-length */
export function zip(...sources) {
    let fn = sources.shift();
    if (typeof fn !== 'function') {
        sources.unshift(fn);
        fn = identityAsync;
    }
    return new ZipAsyncIterable(sources, fn);
}

//# sourceMappingURL=zip.mjs.map