[!NOTE] This is one of 192 standalone projects, maintained as part of the @thi.ng/umbrella monorepo and anti-framework.

🚀 Please help me to work full-time on these projects by sponsoring me on GitHub. Thank you! ❤️

• About
  • Evaluators
  • Iterators
  • Transducers
  • Reducers
• Status
• Installation
• Dependencies
• API
• Authors
• License

About

Async versions of various highly composable transducers, reducers and iterators. This is a support package for @thi.ng/transducers.

Evaluators

• iterator()
• reduce()
• run()
• step()
• transduce()

Iterators

• concat()
• events()
• merge()
• raf()
• range()
• repeatedly()
• sidechain()
• sync()
• zip()

Transducers

• comp()
• filter()
• map()
• mapcat()
• multiplex()
• multiplexObj()
• take()
• throttle()
• throttleTime()

Reducers

• push()

Status

ALPHA - bleeding edge / work-in-progress

Search or submit any issues for this package

Installation

yarn add @thi.ng/transducers-async

ESM import:

import * as txa from "@thi.ng/transducers-async";

Browser ESM import:

<script type="module" src="https://cdn.skypack.dev/@thi.ng/transducers-async"></script>

Skypack documentation

For Node.js REPL:

const txa = await import("@thi.ng/transducers-async");

Package sizes (brotli'd, pre-treeshake): ESM: 2.23 KB

Dependencies

• @thi.ng/api
• @thi.ng/checks
• @thi.ng/compose
• @thi.ng/errors
• @thi.ng/transducers

API

Generated API docs

Authors

• Karsten Schmidt

If this project contributes to an academic publication, please cite it as:

@misc{thing-transducers-async,
  title = "@thi.ng/transducers-async",
  author = "Karsten Schmidt",
  note = "https://thi.ng/transducers-async",
  year = 2018
}

License

© 2018 - 2024 Karsten Schmidt // Apache License 2.0