简介
Fluentflow 是一款基于 Promise 和 Generator（ES7）语法的流式编程库，它可以让你以更加自然和流畅的方式组合和处理异步操作。使用 fluentflow，你可以快速、方便地搭建应用程序，同时减少代码冗余和维护成本。
安装
你可以通过 npm 来安装 fluentflow：
npm install fluentflow --save
使用
为了展示 fluentflow 的功能，我们将使用一个简单的示例：我们想要从一个数据源 API 获取数据，并对数据进行过滤和排序。下面是我们使用 fluentflow 的具体步骤：
第一步：创建数据源
首先，我们需要创建一个数据源，以便下一步的操作。这里我们将使用一个假数据源来模拟这个过程。可以将这个数据源看做是一个返回 Promise 的函数。
-- -------------------- ---- -------
-------- ---------------- -
------ --- --------------- -- -
------------- -- -
---------
- ----- ------ ---- -- --
- ----- -------- ---- -- --
- ----- ------ ---- -- --
- ----- ------- ---- -- --
- ----- ------- ---- -- --
- ----- ------- ---- -- -
---
-- ------
---
-第二步：使用 fluentflow
接下来，我们将使用 fluentflow 对这个数据源进行过滤和排序。具体步骤如下：
首先，我们使用 flow 方法来创建一个 fluentflow 对象。然后，我们使用 source 方法传入我们的数据源，使用 filter 方法对数据进行过滤，最后使用 sort 方法对过滤后的数据进行排序。
-- -------------------- ---- -------
----- -- - ----------------------
----
-------------------------
------------ -- -------- -- -- -- -------- -- ---
--------- -- -- ----- - ------
------------ -- -
--------------------
---上述代码的输出结果将是：
[
{ name: 'Alice', age: 18 },
{ name: 'Tom', age: 20 },
{ name: 'Jane', age: 23 },
{ name: 'Jack', age: 24 }
]API
Fluentflow 的 API 由以下方法构成：
flow()
flow 方法创建一个 fluentflow 对象，你可以使用它来串联下面的方法，并返回 fluentflow 对象本身。
source(promise)
source 方法接受一个 Promise 作为参数，并将 Promise 的值传递给下一个方法链。这个 Promise 可以是一个异步操作的结果，例如一个文件的读取结果或者一个数据源 API 的返回值。
ff()
.source(new Promise(resolve => {
resolve('hello');
}))
.then(result => {
console.log(result); // 'hello'
});filter(callback)
filter 方法接受一个回调函数作为参数，并使用这个回调函数对数据进行筛选，筛选后的数据将传递给下一个方法链。
ff()
.source([1, 2, 3, 4, 5])
.filter(item => item > 3)
.then(result => {
console.log(result); // [4, 5]
});map(callback)
map 方法接受一个回调函数作为参数，并使用这个回调函数对数据进行映射操作，映射后的数据将传递给下一个方法链。
ff()
.source([1, 2, 3])
.map(item => item * 2)
.then(result => {
console.log(result); // [2, 4, 6]
});pluck(key)
pluck 方法接受一个字符串作为参数，它将抽取数据中每个对象的相应属性，组成一个新数组并返回。
-- -------------------- ---- -------
----
---------
- ----- ------ ---- -- --
- ----- ------ ---- -- -
--
--------------
------------ -- -
-------------------- -- ------- ------
---sort(callback)
sort 方法接受一个回调函数作为参数，它将使用这个回调函数对数据进行排序操作，并将排序后的数据传递给下一个方法链。
ff()
.source([3, 2, 1])
.sort()
.then(result => {
console.log(result); // [1, 2, 3]
});each(callback)
each 方法接受一个回调函数作为参数，它将对数据中的每一项使用这个回调函数，并返回一个 Promise，当所有回调函数都执行完毕后，Promise 才会被 resolve。
ff()
.source([1, 2, 3])
.each(item => {
console.log(item);
})
.then(() => {
console.log('done!'); // 'done!'
});reduce(callback [, initialValue])
reduce 方法接受一个回调函数作为参数，它将对数据中的每一项使用这个回调函数，最后将所有结果合并成一个值，并返回。可以使用第二个参数指定合并的起始值。
ff()
.source([1, 2, 3])
.reduce((a, b) => a + b, 0)
.then(result => {
console.log(result); // 6
});结语
至此，你已经了解了 fluentflow 的基本用法，以及它的核心 API。通过 fluentflow，你可以以一种更加自然和优雅的方式组合异步操作，大大减少了代码冗余和维护成本，是一款非常值得尝试的工具。
来源：JavaScript中文网 ，转载请注明来源 https://www.javascriptcn.com/post/69855