An angular component mixin and a pipe operator to automatically unsubscribe when your component is destroyed. Written in Typescript.

Utilities for use with the pipe operator in Kaffeine

Cleanly exit process on EPIPE

pipe streams together and close all of them if one of them closes

Pipe functions in a Unix-like style. It supports Promises (async) anywhere in the pipeline and every step will be executed sequentially. The return (resolve in case of Promises) of each function will be passed in as an argument to the next one

Like JSONStream, but using Minipass streams

Library to make working with Iterators/AsyncIterators easier.

Simplest pipe operator alternative (11 lines of code) with the simplest and shortest syntaxt.

Pipe streams and handle events

Compose promise-returning & async functions into a reusable pipeline

pipe streams with centralized error handling

A simple pipe for buffers

a collection of useful streams

write output to a file through shell commands

JavaScript/TypeScript runtime built on the BEAM VM (Elixir/Erlang) with QuickJS. Erlang/OTP superpowers for JS: lightweight processes, supervision trees, GenServer, pattern matching, pipe operator.

This is a sequel to [stream-combiner](https://npmjs.org/package/stream-combiner) for streams3.

simple stream multiplexing for `objectMode`

[](https://npmjs.org/package/stream-combiner) [](https://travis-ci.org/dominictarr/stream-combiner)

Utility to "pipe" async iterables together

minimal implementation of a PassThrough stream