FxTS

Why FxTS?

Installation

npm install @fxts/core

Documentation

Usage

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)),);// chainingfx(range(10)).map((a)=>a+10).filter((a)=>a%2===0).take(2).each((a)=>console.log(a));

Usage(concurrent)

import{concurrent,countBy,flat,fx,map,pipe,toAsync}from"@fxts/core";// maybe 1 seconds apiconstfetchWiki=(page:string)=>fetch(`https://en.wikipedia.org/w/api.php?action=parse&page=${page}`);constcountWords=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),);awaitcountWords();// 4 secondsawaitcountWords(2);// 2 seconds

Build

Running Test

Running Type Test

License