use stream.pipeline() if available

shinnn · Jul 8, 2019 · e910682 · e910682
1 parent 848ce30
commit e910682
Show file tree

Hide file tree

Showing 3 changed files with 16 additions and 5 deletions.
diff --git a/index.js b/index.js
@@ -1,10 +1,10 @@
 'use strict';
 
 const {inspect, promisify} = require('util');
+const {pipeline, Transform} = require('stream');
 const {resolve} = require('path');
-const {Transform} = require('stream');
 
-const cancelablePump = require('cancelable-pump');
+const cancelablePump = require(`cancelable-${pipeline ? 'pipeline' : 'pump'}`);
 const {Unpack} = require('tar');
 const inspectWithKind = require('inspect-with-kind');
 const isPlainObj = require('is-plain-obj');

diff --git a/package-lock.json b/package-lock.json
diff --git a/package.json b/package.json
@@ -29,6 +29,7 @@
 		"observable"
 	],
 	"dependencies": {
+		"cancelable-pipeline": "^1.0.0",
 		"cancelable-pump": "^0.4.0",
 		"inspect-with-kind": "^1.0.5",
 		"is-plain-obj": "^1.1.0",