-
-
Notifications
You must be signed in to change notification settings - Fork 8
/
index.js
29 lines (25 loc) · 666 Bytes
/
index.js
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
import pMap, {pMapIterable} from 'p-map';
export default async function pFilter(iterable, filterer, options) {
const values = await pMap(
iterable,
(element, index) => Promise.all([filterer(element, index), element]),
options,
);
return values.filter(value => Boolean(value[0])).map(value => value[1]);
}
export function pFilterIterable(iterable, filterer, options) {
const values = pMapIterable(
iterable,
(element, index) => Promise.all([filterer(element, index), element]),
options,
);
return {
async * [Symbol.asyncIterator]() {
for await (const [value, element] of values) {
if (value) {
yield element;
}
}
},
};
}