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 402cfcb457 Initial commit 5 months ago
.gitignore Initial commit 5 months ago Initial commit 5 months ago
example.js Initial commit 5 months ago
index.js Initial commit 5 months ago
package.json Initial commit 5 months ago
yarn.lock Initial commit 5 months 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("@ppstreams/pipe");
const rangeNumbers = require("@ppstreams/range-numbers");
const collect = require("@ppstreams/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.