You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
Sven Slootweg 1ff3b9b535 0.1.1 1 year ago
.gitignore Initial commit 2 years ago Update to new name 1 year ago
example.js Update to new name 1 year ago
index.js Update to new name 1 year ago
package.json 0.1.1 1 year ago
yarn.lock Update to new name 1 year ago


This is a sink stream that's used to collect the results of a pipeline into a single array.

When its read method is called, this stream returns a Promise and then just endlessly reads from its source stream until it receives an EndOfStream. Once the source stream ends, the Promise is resolved with an array containing every value that the collect stream has received.


"use strict";

const Promise = require("bluebird");
const pipe = require("@promistream/pipe");
const rangeNumbers = require("@promistream/range-numbers");
const collect = require("@promistream/collect");

return Promise.try(() => {
	return pipe([
		rangeNumbers(0, 20),
}).then((result) => {
	// [ 0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15, 16, 17, 18, 19 ]



Returns a new collect stream. Takes no arguments.

Stream behaviour:

  • Reads from source: Infinitely, until the end of the source stream is reached.
  • Consumes: Values of any kind.
  • Produces: Returns a Promise when .read() is called, that will resolve with accumulated values received from the source stream when its end is reached, or reject when an error of any kind (including an Aborted marker) is received from the source stream.
  • Throws: Only when an error is received from upstream.
  • Aborts: Never.