介绍
whatwg-streams-fns 是一个可以在浏览器中使用的工具库，它提供了对 WhatWG Streams API 的封装，用于方便地处理数据流。它提供了流的创建、转换、组合等功能，可以帮助我们更有效地处理复杂的数据流。
安装
要使用 whatwg-streams-fns，首先需要通过 npm 安装它。在终端命令行中输入：
npm install whatwg-streams-fns
使用
创建流
你可以使用 from 方法创建一个数据流，例如：
import { from } from 'whatwg-streams-fns';
const stream = from([1, 2, 3]);这将创建一个包含数字 1、2、3 的数据流。你可以通过 pipeTo 方法将数据流发送到目标流或可写流：
import { WritableStream } from 'web-streams-polyfill';
import { from } from 'whatwg-streams-fns';
const stream = from([1, 2, 3]);
const writableStream = new WritableStream();
stream.pipeTo(writableStream);上例中，我们将数据流发送到一个可写流中。你可以通过 pipeThrough 方法对数据流进行转换，在传递给下一个数据流之前，对数据流进行过滤、映射、限制等操作：
-- -------------------- ---- -------
------ - -------------- - ---- -----------------------
------ - ---- - ---- ---------------------
----- ------ - -------- -- ----
----- -------------- - --- -----------------
----- --------- - --------------------
----------------- -
-- ---------- - ------
------------------ - --------------- -
-- ------ -- -- -
-------------------------------------------------------
-----------
-----
--
-
--
-
---
---------------------------------上例中，我们使用 pipeThrough 方法将数据流进行过滤，只留下小于等于 2 的数据发送给下一个数据流。
组合流
whatwg-streams-fns 还提供了一些方法来处理多个流。例如，可以将多个流组合成一个流：
import { combine } from 'whatwg-streams-fns';
const stream1 = from([1, 2, 3]);
const stream2 = from([4, 5, 6]);
const combinedStream = combine(stream1, stream2);上例中，我们将 stream1 和 stream2 组合成一个数据流。你可以通过 pipeTo 或 pipeThrough 方法将数据流传递给下一个数据流或可写流。
处理流
对于已有的数据流，我们也可以使用 whatwg-streams-fns 中提供的方法对数据流进行处理。例如，我们可以使用 map 方法对数据流中的每个元素进行处理：
-- -------------------- ---- ------- ------ - ---- - ---- --------------------- ----- ------ - -------- -- -- ---- ----- --------- - ------------ -- - - --- ------------------------------------ ------ ---- -- -- - ------------------- -- - ---
上例中，我们将数据流中的每个元素乘以 2，然后读取流的第一个元素进行输出。
总结
whatwg-streams-fns 是一个方便处理数据流的工具库，提供了创建、转换、组合等多种功能，可以让我们更加高效地处理数据流，减少冗余代码。在处理复杂的数据流时，whatwg-streams-fns 会是一个非常有用的工具库。
来源：JavaScript中文网 ，转载请注明来源 https://www.javascriptcn.com/post/6006710a8dd3466f61ffe0ac