简介
kefir-takenth 是 Kefir.js 的一个插件，提供了一个 takenth 操作符，用来从流中获取某一项的值。具体使用方法及示例请继续往下阅读。
安装
npm install kefir-takenth --save
使用方法
kefir-takenth 插件提供了一个 takenth 操作符，可以从流中获取某一项的值。takenth 操作符的参数是要获取的项的索引，索引从 0 开始计数。
Kefir.stream([1, 2, 3, 4, 5]) .takenth(3) .onValue(console.log); // 输出：4
takenth 操作符还可以接收一个数组作为参数，用来获取多个项的值。数组的每一项也是一个索引，从 0 开始计数。
Kefir.stream([1, 2, 3, 4, 5]) .takenth([1, 3]) .onValue(console.log); // 输出：[2, 4]
深入理解
虽然 takenth 操作符的功能很简单，但是它背后的实现原理却很有意思。下面我们来深入理解一下它的实现。
tap
在 kefir-takenth 插件的实现中，它用到了 Kefir.js 的 tap 操作符。tap 操作符是用来打印调试信息的，它不会改变流的值。
Kefir.stream([1, 2, 3, 4, 5]) .tap(console.log) // 输出：1, 2, 3, 4, 5 .map(x => x * 2) .tap(console.log) // 输出：2, 4, 6, 8, 10 .onValue(console.log); // 输出：2, 4, 6, 8, 10
在 kefir-takenth 插件的实现中，tap 操作符被用来获取流中某一项的值。只需要在 tap 操作符的回调函数中记录一下当前项的值，即可实现 takenth 操作符。
zip
在实现 takenth 操作符的示例中，我们使用了 zip 操作符。它的作用是将多个流合并成一个流，每次合并时返回对应位置的每个流元素。
const a$ = Kefir.sequentially(1000, [1, 2, 3]); const b$ = Kefir.sequentially(2000, [4, 5, 6]); Kefir.zip([a$, b$]) .onValue(console.log); // 输出：[1, 4], [2, 5], [3, 6]
在 kefir-takenth 插件的实现中，它被用来将 tap 操作符中记录的项和流元素一一对应起来，从而实现 takenth 操作符。
示例代码
-- -------------------- ---- ------- ----- ----- - ----------------- ------------------------- -- ---- ---------------- -- -- -- --- ----------- ---------------------- -- ---- -- ---- ---------------- -- -- -- --- ------------ --- ---------------------- -- ------ -- -- ---- --------------------- ----- -- - ------------------------ ----- ---- ---- ---- ------ ---------- -- -- ------------------- -------- ------------ --- -- --- --------------- --------- --- -- -- ---------------------- -- ----- -
结语
通过阅读本文，我们学习了 kefir-takenth 插件的使用方法及背后的实现原理。希望本文对你有所帮助。
来源：JavaScript中文网 ，转载请注明来源 https://www.javascriptcn.com/post/60066eff4c49986ca68d8bbb