Skip to content

Main NavigationGuide Reference

Appearance

Sidebar Navigation

Filtering

filter reject find findWhere compact uniq uniqBy where drop head last slice take

Transforming

map omit pick pluck reduce reduce1 flatMap flatten

Grouping

collect batch keyBy groupBy

Working with buffers

split splitBy csv csvStringify decode encode

Flow control

ratelimit throttle

Handling Promises

resolve massThen massCatch makeAsync asyncFilter asyncReduce

Handling errors

errors stopOnError stopWhen

Sorting

Transforming sorted data sources

sortedGroupBy sortedJoin

Side effects

Combining streams

merge fork observe through pipeline

Consuming streams

toArray toPromise pull pipe each value values start consume consumeSync

Node.js streams interop

toAsyncIterator toNodeStream

Controlling data flow

resume pause end destroy

Exstream.through(target)

TODO

Last updated:

Previous pageobserve

Next pagepipeline

Released under the MIT License.

Copyright © 2019-present Michele Triaca