		var through = require('through2');
		var pipeline = require('stream-combiner2');
		var pipeline = require('../../modifiers/pipeline.js');

		@@ -4,0 +4,0 @@ var parse = require('../../modifiers/parse.js');

lib/index.js

		@@ -13,3 +13,3 @@ var selectVersion = require('./consumers/selectVersion.js');
		var split = require('split2');
		var pipeline = require('stream-combiner2');
		var pipeline = require('./modifiers/pipeline.js');
		var through = require('through2');
		@@ -35,2 +35,3 @@ var filter = require('./modifiers/filter.js');
		// Modifiers
		module.exports.pipeline = pipeline;
		module.exports.filter = filter;
		@@ -65,19 +66,2 @@ module.exports.map = map;
		/**
		* Returns a new stream that writes to the first given stream and reads from
		* the last given stream. All errors are routed to the new output stream. This is a
		* wrapper of [stream-combiner2]{@link https://www.npmjs.com/package/stream-combiner2}
		* by [substack]{@link https://github.com/substack}.
		*
		* @method
		* @static
		* @since 1.0.0
		* @category Util
		*
		* @param {...(Function\|Function[])} streams - A series of streams that will be combined
		* into a single output stream.
		* @returns {Stream} - Transform stream.
		*/
		module.exports.pipeline = pipeline;

		/**
		* Returns a transform stream with a simple API. This is a wrapper of
		@@ -84,0 +68,0 @@ * [through2]{@link https://www.npmjs.com/package/through2} by

lib/modifiers/sort.js

		var _ = require('lodash');
		var through = require('through2');
		var pipeline = require('stream-combiner2');

		var pipeline = require('./pipeline.js');
		var wait = require('../consumers/v2/wait.js');
		@@ -6,0 +6,0 @@ var map = require('./map.js');

package.json

		{
		"name": "node-stream",
		"version": "1.3.0",
		"version": "1.3.1",
		"description": "Utilities for consuming, creating and manipulating node streams.",
		@@ -5,0 +5,0 @@ "main": "lib/index.js",

node-stream - npm Package Compare versions

New alerts