Handle a lot of files on Linux (#65)

lib/linux.js

@@ -1,9 +1,11 @@
 'use strict';
+const os = require('os');
 const path = require('path');
 const fsExtra = require('fs-extra');
 const pify = require('pify');
 const uuid = require('uuid');
 const xdgTrashdir = require('xdg-trashdir');
+const pMap = require('p-map');
 
 const fs = pify(fsExtra);
 
@@ -28,4 +30,4 @@ DeletionDate=${(new Date()).toISOString()}
 	});
 }
 
-module.exports = paths => Promise.all(paths.map(trash));
+module.exports = paths => pMap(paths, trash, {concurrency: os.cpus().length});

package.json

@@ -42,6 +42,7 @@
     "escape-string-applescript": "^2.0.0",
     "fs-extra": "^0.30.0",
     "globby": "^7.1.1",
+    "p-map": "^1.2.0",
     "p-try": "^1.0.0",
     "pify": "^3.0.0",
     "run-applescript": "^3.0.0",

test.js

@@ -101,6 +101,21 @@ test('directories', async t => {
 	t.false(fs.existsSync(321));
 });
 
+(process.platform === 'linux' ? test : test.failing)('tons of files', async t => {
+	const FILE_COUNT = 5000;
+	const paths = [];
+	for (let i = 0; i < FILE_COUNT; i++) {
+		paths.push('file' + i);
+		fs.writeFileSync('file' + i, '');
+	}
+
+	await t.notThrows(m(paths));
+
+	for (let i = 0; i < FILE_COUNT; i++) {
+		t.false(fs.existsSync('file' + i));
+	}
+});
+
 test('symlinks', async t => {
 	fs.writeFileSync('aaa', '');
 	fs.symlinkSync('aaa', 'bbb');