feat: Support configuring how workers are invoked

Author: justinvdm

index.js

@@ -9,6 +9,7 @@ class FileProcessor extends EventEmitter {
     super();
     options = options || {};
     const glob = (this.glob = globStream(globPattern));
+    this.invokeWorker = options.invokeWorker || defaultInvokeWorker;
     const workers = (this.workers = workerFarm(options.worker || {}, worker));
 
     let allQueued = false;
@@ -49,7 +50,7 @@ class FileProcessor extends EventEmitter {
   }
 
   process(path, callback) {
-    this.workers(path, callback);
+    this.invokeWorker(this.workers, path, callback);
   }
 
   destroy(callback) {
@@ -58,4 +59,8 @@ class FileProcessor extends EventEmitter {
   }
 }
 
+function defaultInvokeWorker(workers, path, callback) {
+  workers(path, callback);
+}
+
 module.exports = FileProcessor;

test/index.spec.js

@@ -111,4 +111,28 @@ describe('success', () => {
       });
     });
   });
+
+  test('invokeWorker', () => {
+    expect.assertions(3);
+
+    const processor = new FileProcessor(pattern, workerPath, {
+      invokeWorker(workers, filepath, callback) {
+        workers(filepath, (err, result) =>
+          err ? callback(err) : callback(null, `${result}!`)
+        );
+      },
+    });
+
+    const handler = jest.fn();
+    processor.on('processed', handler);
+
+    return new Promise((resolve) => {
+      processor.on('end', () => {
+        expect(handler).toHaveBeenCalledWith(examplePath('1.txt'), 'a!');
+        expect(handler).toHaveBeenCalledWith(examplePath('2.txt'), 'b!');
+        expect(handler).toHaveBeenCalledWith(examplePath('3.txt'), 'c!');
+        resolve();
+      });
+    });
+  });
 });