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

export async function count(source, fn = async () => true) {
    let i = 0;
    for await (const item of source) {
        if (await fn(item)) {
            i++;
        }
    }
    return i;
}

//# sourceMappingURL=count.mjs.map