FxTS


FxTS is a functional programming library for TypeScript.

- Provides lazy evaluation for memory-efficient data processing with functions like pipe, map, filter, and take.
- Handles concurrent requests efficiently with concurrent and toAsync.
- Offers excellent TypeScript support with strong type inference.
- Follows standard iteration protocols (Iterable/AsyncIterable).

Installation

``
npm install @fxts/core
`

Usage

Use pipe for function composition or fx for method chaining:

`ts
import { each, filter, fx, map, pipe, range, take } from "@fxts/core";

pipe(
range(10),
map((a) => a + 10),
filter((a) => a % 2 === 0),
take(2),
each((a) => console.log(a)),
);

// chaining
fx(range(10))
.map((a) => a + 10)
.filter((a) => a % 2 === 0)
.take(2)
.each((a) => console.log(a));
`

Usage (concurrent)

Handle multiple async operations in parallel with concurrent:

`ts
import { concurrent, countBy, flat, fx, map, pipe, toAsync } from "@fxts/core";

// maybe 1 seconds api
const fetchWiki = (page: string) =>
fetch(https://en.wikipedia.org/w/api.php?action=parse&page=${page});

const countWords = async (concurrency: number) =>
pipe(
["html", "css", "javascript", "typescript"],
toAsync,
map(fetchWiki),
map((res) => res.text()),
map((words) => words.split(" ")),
flat,
concurrent(concurrency),
countBy((word) => word),
);

await countWords(); // 4 seconds
await countWords(2); // 2 seconds
``

Documentation

For more information, visit fxts.dev.

For LLM-friendly documentation, see llms.txt.

Contributing

We welcome contributions from everyone in the community. Please read our Contributing Guide.

License

Apache License 2.0 © Marpple. See LICENSE for details.