es-toolkit/iterator 指南用惰性求值迭代器构建高性能数据处理管道【免费下载链接】es-toolkitA modern JavaScript utility library thats 2-3 times faster and up to 97% smaller, a major upgrade to lodash.项目地址: https://gitcode.com/GitHub_Trending/es/es-toolkites-toolkit/iterator是 es-toolkit 项目中专门面向 JavaScript 迭代器Iterator设计的惰性求值lazy evaluation工具模块。它不会像数组函数那样在每一步构建中间数组而是让元素逐个流过管道、只计算实际被消费的部分。读完本文你将掌握该模块的全部 12 个函数、它与原生迭代器 Helper 的协作方式、处理无限序列与资源清理的实践以及如何通过es-toolkit/fp/iterator与pipe组合出声明式管道并据此判断何时该用es-toolkit/iterator而非普通数组函数。什么是 es-toolkit/iterator在 JavaScript 中处理大型数据集时传统做法是先把数据放进数组再用map、filter等方法逐步处理。这种方式的代价是每个中间步骤都会生成一个全新的数组数据量越大内存占用越高且很多元素可能根本不需要被处理。es-toolkit/iterator提供的是惰性求值的迭代器帮助函数管道中的元素一次只处理一个只有实际被消费到的部分才会真正执行计算。官方文档给出了最典型的示例import { takeWhile } from es-toolkit/iterator; takeWhile(hugeArray.values(), x x 100) .map(expensiveTransform) // 原生迭代器 Helper .toArray(); // expensiveTransform 只对开头小于 100 的那些元素执行这里的关键在于map(expensiveTransform)是 JavaScript 原生的迭代器 Helper它在链式调用中不会立即执行而是等到.toArray()真正消费时才逐元素运行。由于前面的takeWhile已经截断了不满足条件的元素expensiveTransform这个昂贵变换只会在 100的前缀元素上执行——即使hugeArray有上百万个元素只要第 100 万个元素不小于 100后面的元素根本不会被触碰。函数清单es-toolkit/iterator共导出 12 个函数见 src/iterator/index.ts函数用途cartesianProduct多个迭代器的笛卡尔积chunk将元素按固定大小分组count统计元素个数不分配数组dropWhile跳过满足条件的前缀元素head取出第一个元素iterate由种子值反复应用函数生成无限序列partition按谓词拆分为两组range惰性数字区间scan左折叠并输出每一步中间结果takeWhile取满足条件的前缀元素uniqBy按键去重zip多个迭代器按位置配对这些函数覆盖了原生迭代器 Helper 所没有的能力条件式截断、带状态的操作、以及多数据源组合。函数的工作机制IteratorObject 与原生 Helper 的无缝衔接该模块的所有函数都以Iterator作为第一个参数。这个Iterator可以是array.values()返回的值迭代器生成器函数generator function返回的生成器Map/Set的迭代器如map.keys()、set.values()其他任意实现了迭代器协议的对象。惰性求值的函数会返回一个以原生Iterator.prototype为原型的IteratorObject。这意味着返回值天然带有全部原生迭代器 Helpermap、filter、take、drop、flatMap、reduce、toArray等可以和它们无缝链式调用。这一设计在内部实现中体现得十分彻底。核心辅助函数位于 src/iterator/_internal/iterator.ts它把一个手写的next函数包装成惰性IteratorObjectconst result Object.create(Iterator.prototype) as IteratorObjectT, undefined { next: () IteratorResultT, undefined; return: () IteratorResultT, undefined; }; result.next function () { if (closed) { return { value: undefined, done: true }; } let step; try { step next(); } catch (error) { close(); throw error; } if (step.done) { close(); } return step; }; result.return function () { close(); return { value: undefined, done: true }; };从源码结构可以读出两个重要的设计决策性能优先注释中明确说明之所以用手写的next而不是生成器函数是因为直接驱动迭代器协议在同一变换下实测约为yield生成器的两倍快而Object.create(Iterator.prototype)相对普通对象字面量没有可测量的开销。完整的 IteratorClose 协议onClose回调保证只执行一次触发时机为以下三者中最早发生的一个——消费者提前终止return()例如take截断或for...of中break、next抛出异常、next报告done。迭代器关闭后next永远不会再被调用后续每一步都直接返回done。原生 Helper 覆盖不到的角落原生Iterator.prototype已经提供了按数量取元素的take和drop、以及map、filter等基础操作所以 es-toolkit 只补充原生 Helper 缺失的能力条件式操作、带状态的操作、以及处理多个数据源的操作。以takeWhile为例它正是对原生take的谓词化补充export function takeWhileT( source: IteratorT, shouldContinue: (value: T, index: number) boolean ): IteratorObjectT, undefined { let index 0; return iterator( function () { const result source.next(); if (result.done || !shouldContinue(result.value, index)) { return { value: undefined, done: true }; } return { value: result.value, done: false }; }, () void source.return?.() ); }注意shouldContinue回调接收(value, index)两个参数便于在谓词中利用位置信息一旦谓词返回 falsy迭代立即终止剩余元素永远不会从上游拉取且通过onClose回调关闭上游迭代器。再如scan实现的扫描左折叠它像reduce一样累积状态但会把每一步的中间结果都作为值产出初始值最先产出输入长度为n时输出长度为n 1这是原生 Helper 没有的语义scan([1, 2, 3].values(), (acc, x) acc x, 0).toArray(); // [0, 1, 3, 6]回调签名为(accumulator, value, index)其中索引从 0 开始计数。惰性求值与无限序列惰性求值的核心原则是没有被要求计算的元素一个都不会被计算。把惰性函数与可以中途截断的原生 Helper如take组合就能实际处理无限序列。文档中的经典例子是用iterate按需生成 2 的幂import { iterate } from es-toolkit/iterator; // 在需要的时候才生成 2 的幂 iterate(1, x x * 2) .take(5) .toArray(); // [1, 2, 4, 8, 16]iterate(seed, getNext)生成seed、getNext(seed)、getNext(getNext(seed))……的无限序列。从 iterate.ts 的实现可以看出它内部只维护current与started两个状态每次next调用时才计算下一个值在此之前零计算发生。因为序列是无限的所以必须配合take或takeWhile这类短路 Helper 才能消费。类似的还有range与 es-toolkit 数组中一次性返回数组的range不同这里的range返回惰性IteratorObject支持三种重载range(4).toArray(); // [0, 1, 2, 3] range(1, 4).toArray(); // [1, 2, 3] range(0, 20, 5).toArray(); // [0, 5, 10, 15] range(0, -4, -1).toArray(); // [0, -1, -2, -3]当只传一个参数时它作为end开区间start默认为 0步长step默认为 1支持负数实现递减区间。实现中对步长做了校验若非整数或为 0会抛出The step value must be a non-zero integer, but got ...的异常range.ts。zip与无限序列的组合也经过了专门设计。与数组版zip不同数组版会填充到最长长度迭代器版zip在最短的源耗尽时立即停止这使得它可以安全地搭配无限迭代器使用zip(range(0, Infinity), names.values()) // 以 names 耗尽为结束信号当迭代结束——无论是因为某个源耗尽还是消费者提前终止——所有源都会通过return方法被关闭见 zip.ts 的onClose回调。一次性消费特性与资源清理与 JavaScript 中所有迭代器一样该模块返回的结果只能被消费一次一旦消费完毕就不再产生任何元素。这一点与数组函数有本质区别——数组可以反复遍历而迭代器是单向通道。更值得关注的是提前终止时的资源清理。当管道提前停止时——take达到上限、for...of循环break、回调抛出异常——源迭代器会通过return方法被关闭从而确保生成器源中try/finally的清理代码一定会执行。文档用文件读取的例子说明了这个能力import { chunk } from es-toolkit/iterator; function* lines() { const file open(data.txt); try { yield* file.readLines(); } finally { file.close(); // 即使消费方提前停止也会执行 } } chunk(lines(), 100).take(2).toArray();这里lines()是一个生成器正常情况下它逐行产出文件内容并在finally中关闭文件句柄。当消费方用.take(2)只读取两批每批 100 行就结束消费时迭代器协议会调用生成器的return()finally块随即执行文件被正确关闭——不会泄漏句柄。这一保证的底层来源正是前面提到的iterator内部辅助函数它的close()只执行一次onClose而每个公共函数如takeWhile、chunk、scan、zip都把() void source.return?.()作为onClose传入形成了消费者终止 → 上游关闭 → 资源释放的完整链路。终端操作示例模块中还有两个非惰性的终端操作head取出第一个元素后立即通过return关闭源迭代器与原生Iterator.prototype.find行为一致因此它对无限迭代器也安全但取完后源不可再遍历。空迭代器返回undefined。count拉取全部元素并返回个数。它是终端操作不能用于无限迭代器。与source.toArray().length相比它计数时不分配数组内存更友好。与 pipe 组合fp/iterator 的柯里化形式所有操作都可以与pipe组合使用。为此每个函数都提供了柯里化版本集中导出在es-toolkit/fp/iterator子路径下见 src/fp/iterator/index.ts其中包括es-toolkit 自身的惰性函数cartesianProduct、chunk、count、dropWhile、head、partition、scan、takeWhile、uniqBy、zip原生迭代器 Helper 的 pipe 包装器map、filter、take、drop、flatMap、every、some、find、forEach、reduce、toArray。文档中的完整示例import { pipe } from es-toolkit/fp; import { filter, map, take, toArray } from es-toolkit/fp/iterator; pipe( hugeArray.values(), filter(x x % 2 0), map(x x * 10), take(2), toArray() ); // [20, 40]这条管道从左到右读起来非常直观取偶数 → 乘 10 → 只要前两个 → 收集成数组。由于所有步骤都是惰性的hugeArray中只有满足条件的偶数被真正变换且一旦凑齐两个结果上游立即停止——这正是 fp 风格与惰性求值结合的威力所在。何时使用 iterator 而非数组函数文档最后给出了明确的分工建议这也是选择 API 的决策依据数据已经是数组、且需要处理全量数据时es-toolkit的数组函数如 array 目录 下的map、filter、uniq等是合适的默认选择满足以下任一条件时请使用es-toolkit/iterator输入规模很大甚至是无限的管道可能提前结束例如只关心前 N 个匹配结果数据本身已经以迭代器或生成器的形式到达例如逐行读取流、数据库游标、事件序列。两者的本质区别在于计算策略数组函数是先算完再交付的急求值eager迭代器函数是用到才算的惰性求值lazy。对于大型或无限数据流后者既能避免中间数组的内存浪费又能借助短路操作大幅减少无效计算。小结es-toolkit/iterator是一个小而精的惰性求值工具集12 个函数补齐了原生迭代器 Helper 缺失的条件式、状态式与多源组合能力统一返回IteratorObject与原生 Helper 无缝链式调用基于Object.create(Iterator.prototype)的手写next实现见 src/iterator/_internal/iterator.ts在保持完整 IteratorClose 协议的同时获得优于生成器的性能天然支持无限序列与提前终止并保证上游资源如文件句柄通过return/finally正确释放es-toolkit/fp/iterator提供柯里化版本可与pipe组合成声明式管道。如果你的下一份代码要处理大文件、无限流或只需要前几个结果的场景这个模块就是比数组函数更合适的起点。更完整的函数签名与示例可继续查阅 docs/iterator/reference 目录下的各函数文档。【免费下载链接】es-toolkitA modern JavaScript utility library thats 2-3 times faster and up to 97% smaller, a major upgrade to lodash.项目地址: https://gitcode.com/GitHub_Trending/es/es-toolkit创作声明：本文部分内容由AI辅助生成（AIGC），仅供参考 
长河君 · 2026/9/17 3:15:17 · 阅读 1.2k es-toolkit/iterator 指南：用惰性求值迭代器构建高性能数据处理管道
es-toolkit/iterator 指南用惰性求值迭代器构建高性能数据处理管道【免费下载链接】es-toolkitA modern JavaScript utility library thats 2-3 times faster and up to 97% smaller, a major upgrade to lodash.项目地址: https://gitcode.com/GitHub_Trending/es/es-toolkites-toolkit/iterator是 es-toolkit 项目中专门面向 JavaScript 迭代器Iterator设计的惰性求值lazy evaluation工具模块。它不会像数组函数那样在每一步构建中间数组而是让元素逐个流过管道、只计算实际被消费的部分。读完本文你将掌握该模块的全部 12 个函数、它与原生迭代器 Helper 的协作方式、处理无限序列与资源清理的实践以及如何通过es-toolkit/fp/iterator与pipe组合出声明式管道并据此判断何时该用es-toolkit/iterator而非普通数组函数。什么是 es-toolkit/iterator在 JavaScript 中处理大型数据集时传统做法是先把数据放进数组再用map、filter等方法逐步处理。这种方式的代价是每个中间步骤都会生成一个全新的数组数据量越大内存占用越高且很多元素可能根本不需要被处理。es-toolkit/iterator提供的是惰性求值的迭代器帮助函数管道中的元素一次只处理一个只有实际被消费到的部分才会真正执行计算。官方文档给出了最典型的示例import { takeWhile } from es-toolkit/iterator; takeWhile(hugeArray.values(), x x 100) .map(expensiveTransform) // 原生迭代器 Helper .toArray(); // expensiveTransform 只对开头小于 100 的那些元素执行这里的关键在于map(expensiveTransform)是 JavaScript 原生的迭代器 Helper它在链式调用中不会立即执行而是等到.toArray()真正消费时才逐元素运行。由于前面的takeWhile已经截断了不满足条件的元素expensiveTransform这个昂贵变换只会在 100的前缀元素上执行——即使hugeArray有上百万个元素只要第 100 万个元素不小于 100后面的元素根本不会被触碰。函数清单es-toolkit/iterator共导出 12 个函数见 src/iterator/index.ts函数用途cartesianProduct多个迭代器的笛卡尔积chunk将元素按固定大小分组count统计元素个数不分配数组dropWhile跳过满足条件的前缀元素head取出第一个元素iterate由种子值反复应用函数生成无限序列partition按谓词拆分为两组range惰性数字区间scan左折叠并输出每一步中间结果takeWhile取满足条件的前缀元素uniqBy按键去重zip多个迭代器按位置配对这些函数覆盖了原生迭代器 Helper 所没有的能力条件式截断、带状态的操作、以及多数据源组合。函数的工作机制IteratorObject 与原生 Helper 的无缝衔接该模块的所有函数都以Iterator作为第一个参数。这个Iterator可以是array.values()返回的值迭代器生成器函数generator function返回的生成器Map/Set的迭代器如map.keys()、set.values()其他任意实现了迭代器协议的对象。惰性求值的函数会返回一个以原生Iterator.prototype为原型的IteratorObject。这意味着返回值天然带有全部原生迭代器 Helpermap、filter、take、drop、flatMap、reduce、toArray等可以和它们无缝链式调用。这一设计在内部实现中体现得十分彻底。核心辅助函数位于 src/iterator/_internal/iterator.ts它把一个手写的next函数包装成惰性IteratorObjectconst result Object.create(Iterator.prototype) as IteratorObjectT, undefined { next: () IteratorResultT, undefined; return: () IteratorResultT, undefined; }; result.next function () { if (closed) { return { value: undefined, done: true }; } let step; try { step next(); } catch (error) { close(); throw error; } if (step.done) { close(); } return step; }; result.return function () { close(); return { value: undefined, done: true }; };从源码结构可以读出两个重要的设计决策性能优先注释中明确说明之所以用手写的next而不是生成器函数是因为直接驱动迭代器协议在同一变换下实测约为yield生成器的两倍快而Object.create(Iterator.prototype)相对普通对象字面量没有可测量的开销。完整的 IteratorClose 协议onClose回调保证只执行一次触发时机为以下三者中最早发生的一个——消费者提前终止return()例如take截断或for...of中break、next抛出异常、next报告done。迭代器关闭后next永远不会再被调用后续每一步都直接返回done。原生 Helper 覆盖不到的角落原生Iterator.prototype已经提供了按数量取元素的take和drop、以及map、filter等基础操作所以 es-toolkit 只补充原生 Helper 缺失的能力条件式操作、带状态的操作、以及处理多个数据源的操作。以takeWhile为例它正是对原生take的谓词化补充export function takeWhileT( source: IteratorT, shouldContinue: (value: T, index: number) boolean ): IteratorObjectT, undefined { let index 0; return iterator( function () { const result source.next(); if (result.done || !shouldContinue(result.value, index)) { return { value: undefined, done: true }; } return { value: result.value, done: false }; }, () void source.return?.() ); }注意shouldContinue回调接收(value, index)两个参数便于在谓词中利用位置信息一旦谓词返回 falsy迭代立即终止剩余元素永远不会从上游拉取且通过onClose回调关闭上游迭代器。再如scan实现的扫描左折叠它像reduce一样累积状态但会把每一步的中间结果都作为值产出初始值最先产出输入长度为n时输出长度为n 1这是原生 Helper 没有的语义scan([1, 2, 3].values(), (acc, x) acc x, 0).toArray(); // [0, 1, 3, 6]回调签名为(accumulator, value, index)其中索引从 0 开始计数。惰性求值与无限序列惰性求值的核心原则是没有被要求计算的元素一个都不会被计算。把惰性函数与可以中途截断的原生 Helper如take组合就能实际处理无限序列。文档中的经典例子是用iterate按需生成 2 的幂import { iterate } from es-toolkit/iterator; // 在需要的时候才生成 2 的幂 iterate(1, x x * 2) .take(5) .toArray(); // [1, 2, 4, 8, 16]iterate(seed, getNext)生成seed、getNext(seed)、getNext(getNext(seed))……的无限序列。从 iterate.ts 的实现可以看出它内部只维护current与started两个状态每次next调用时才计算下一个值在此之前零计算发生。因为序列是无限的所以必须配合take或takeWhile这类短路 Helper 才能消费。类似的还有range与 es-toolkit 数组中一次性返回数组的range不同这里的range返回惰性IteratorObject支持三种重载range(4).toArray(); // [0, 1, 2, 3] range(1, 4).toArray(); // [1, 2, 3] range(0, 20, 5).toArray(); // [0, 5, 10, 15] range(0, -4, -1).toArray(); // [0, -1, -2, -3]当只传一个参数时它作为end开区间start默认为 0步长step默认为 1支持负数实现递减区间。实现中对步长做了校验若非整数或为 0会抛出The step value must be a non-zero integer, but got ...的异常range.ts。zip与无限序列的组合也经过了专门设计。与数组版zip不同数组版会填充到最长长度迭代器版zip在最短的源耗尽时立即停止这使得它可以安全地搭配无限迭代器使用zip(range(0, Infinity), names.values()) // 以 names 耗尽为结束信号当迭代结束——无论是因为某个源耗尽还是消费者提前终止——所有源都会通过return方法被关闭见 zip.ts 的onClose回调。一次性消费特性与资源清理与 JavaScript 中所有迭代器一样该模块返回的结果只能被消费一次一旦消费完毕就不再产生任何元素。这一点与数组函数有本质区别——数组可以反复遍历而迭代器是单向通道。更值得关注的是提前终止时的资源清理。当管道提前停止时——take达到上限、for...of循环break、回调抛出异常——源迭代器会通过return方法被关闭从而确保生成器源中try/finally的清理代码一定会执行。文档用文件读取的例子说明了这个能力import { chunk } from es-toolkit/iterator; function* lines() { const file open(data.txt); try { yield* file.readLines(); } finally { file.close(); // 即使消费方提前停止也会执行 } } chunk(lines(), 100).take(2).toArray();这里lines()是一个生成器正常情况下它逐行产出文件内容并在finally中关闭文件句柄。当消费方用.take(2)只读取两批每批 100 行就结束消费时迭代器协议会调用生成器的return()finally块随即执行文件被正确关闭——不会泄漏句柄。这一保证的底层来源正是前面提到的iterator内部辅助函数它的close()只执行一次onClose而每个公共函数如takeWhile、chunk、scan、zip都把() void source.return?.()作为onClose传入形成了消费者终止 → 上游关闭 → 资源释放的完整链路。终端操作示例模块中还有两个非惰性的终端操作head取出第一个元素后立即通过return关闭源迭代器与原生Iterator.prototype.find行为一致因此它对无限迭代器也安全但取完后源不可再遍历。空迭代器返回undefined。count拉取全部元素并返回个数。它是终端操作不能用于无限迭代器。与source.toArray().length相比它计数时不分配数组内存更友好。与 pipe 组合fp/iterator 的柯里化形式所有操作都可以与pipe组合使用。为此每个函数都提供了柯里化版本集中导出在es-toolkit/fp/iterator子路径下见 src/fp/iterator/index.ts其中包括es-toolkit 自身的惰性函数cartesianProduct、chunk、count、dropWhile、head、partition、scan、takeWhile、uniqBy、zip原生迭代器 Helper 的 pipe 包装器map、filter、take、drop、flatMap、every、some、find、forEach、reduce、toArray。文档中的完整示例import { pipe } from es-toolkit/fp; import { filter, map, take, toArray } from es-toolkit/fp/iterator; pipe( hugeArray.values(), filter(x x % 2 0), map(x x * 10), take(2), toArray() ); // [20, 40]这条管道从左到右读起来非常直观取偶数 → 乘 10 → 只要前两个 → 收集成数组。由于所有步骤都是惰性的hugeArray中只有满足条件的偶数被真正变换且一旦凑齐两个结果上游立即停止——这正是 fp 风格与惰性求值结合的威力所在。何时使用 iterator 而非数组函数文档最后给出了明确的分工建议这也是选择 API 的决策依据数据已经是数组、且需要处理全量数据时es-toolkit的数组函数如 array 目录 下的map、filter、uniq等是合适的默认选择满足以下任一条件时请使用es-toolkit/iterator输入规模很大甚至是无限的管道可能提前结束例如只关心前 N 个匹配结果数据本身已经以迭代器或生成器的形式到达例如逐行读取流、数据库游标、事件序列。两者的本质区别在于计算策略数组函数是先算完再交付的急求值eager迭代器函数是用到才算的惰性求值lazy。对于大型或无限数据流后者既能避免中间数组的内存浪费又能借助短路操作大幅减少无效计算。小结es-toolkit/iterator是一个小而精的惰性求值工具集12 个函数补齐了原生迭代器 Helper 缺失的条件式、状态式与多源组合能力统一返回IteratorObject与原生 Helper 无缝链式调用基于Object.create(Iterator.prototype)的手写next实现见 src/iterator/_internal/iterator.ts在保持完整 IteratorClose 协议的同时获得优于生成器的性能天然支持无限序列与提前终止并保证上游资源如文件句柄通过return/finally正确释放es-toolkit/fp/iterator提供柯里化版本可与pipe组合成声明式管道。如果你的下一份代码要处理大文件、无限流或只需要前几个结果的场景这个模块就是比数组函数更合适的起点。更完整的函数签名与示例可继续查阅 docs/iterator/reference 目录下的各函数文档。【免费下载链接】es-toolkitA modern JavaScript utility library thats 2-3 times faster and up to 97% smaller, a major upgrade to lodash.项目地址: https://gitcode.com/GitHub_Trending/es/es-toolkit创作声明：本文部分内容由AI辅助生成（AIGC），仅供参考