Improve stream handling (#13)

Co-authored-by: Sindre Sorhus <[email protected]>

Author: sholladay

.github/workflows/main.yml

@@ -12,8 +12,6 @@ jobs:
         node-version:
           - 14
           - 12
-          - 10
-          - 8
     steps:
       - uses: actions/checkout@v2
       - uses: actions/setup-node@v1

index.js

@@ -1,32 +1,19 @@
 'use strict';
 const {promisify} = require('util');
 const path = require('path');
+const stream = require('stream');
 const fs = require('graceful-fs');
 const isStream = require('is-stream');
 const makeDir = require('make-dir');
 const uuid = require('uuid');
 const tempDir = require('temp-dir');
 
 const writeFileP = promisify(fs.writeFile);
+const pipelineP = promisify(stream.pipeline);
 
 const tempfile = filePath => path.join(tempDir, uuid.v4(), (filePath || ''));
 
-const writeStream = async (filePath, fileContent) => new Promise((resolve, reject) => {
-	const writable = fs.createWriteStream(filePath);
-
-	fileContent
-		.on('error', error => {
-			// Be careful to reject before writable.end(), otherwise the writable's
-			// 'finish' event will fire first and we will resolve the promise
-			// before we reject it.
-			reject(error);
-			fileContent.unpipe(writable);
-			writable.end();
-		})
-		.pipe(writable)
-		.on('error', reject)
-		.on('finish', resolve);
-});
+const writeStream = async (filePath, data) => pipelineP(data, fs.createWriteStream(filePath));
 
 module.exports = async (fileContent, filePath) => {
 	const tempPath = tempfile(filePath);

package.json

@@ -11,7 +11,7 @@
 		"url": "https://sindresorhus.com"
 	},
 	"engines": {
-		"node": ">=8"
+		"node": ">=12"
 	},
 	"scripts": {
 		"test": "xo && ava && tsd"