FxTS

FxTS is a functional library for TypeScript/JavaScript programmers.

Why FxTS?

• Lazy evaluation
• Handling concurrent requests
• Type inference
• Follow iteration protocols Iterable / AsyncIterable

Installation

npm install @fxts/core

Documentation

Please review the API documentation

Usage

1import { each, filter, fx, map, pipe, range, take } from "@fxts/core";
2
3pipe(
4  range(10),
5  map((a) => a + 10),
6  filter((a) => a % 2 === 0),
7  take(2),
8  each((a) => console.log(a)),
9);
10
11// chaining
12fx(range(10))
13  .map((a) => a + 10)
14  .filter((a) => a % 2 === 0)
15  .take(2)
16  .each((a) => console.log(a));

Usage(concurrent)

1import { concurrent, countBy, flat, fx, map, pipe, toAsync } from "@fxts/core";
2
3// maybe 1 seconds api
4const fetchWiki = (page: string) =>
5  fetch(`https://en.wikipedia.org/w/api.php?action=parse&page=${page}`);
6
7const countWords = async (concurrency: number) =>
8  pipe(
9    ["html", "css", "javascript", "typescript"],
10    toAsync,
11    map(fetchWiki),
12    map((res) => res.text()),
13    map((words) => words.split(" ")),
14    flat,
15    concurrent(concurrency),
16    countBy((word) => word),
17  );
18
19await countWords(); // 4 seconds
20await countWords(2); // 2 seconds

you can start here

Build

• npm run build

Running Test

• npm test

Running Type Test

• npm run compile:check

License

Apache License 2.0