Merge pull request #259 from digital-value-apps/fix_allow_falsy_args

fix(): do not remove falsy values from queue.process args

lib/bull.explorer.ts

@@ -79,7 +79,7 @@ export class BullExplorer implements OnModuleInit {
       options && options.concurrency,
       instance[key].bind(instance) as ProcessCallbackFunction<unknown>,
     ];
-    args = args.filter(item => item);
+    args = args.filter(item => item !== undefined);
     queue.process.call(queue, ...args);
   }
 

lib/test/bull.explorer.spec.ts

@@ -29,6 +29,16 @@ describe('bullExplorer', () => {
         expect.any(Function),
       );
     });
+    it('should add the given function to the queue handlers with concurrency with a 0 value', () => {
+      const instance = { handler: jest.fn() };
+      const queue = { process: jest.fn() } as any;
+      const opts = { concurrency: 0 };
+      bullExplorer.handleProcessor(instance, 'handler', queue, opts);
+      expect(queue.process).toHaveBeenCalledWith(
+        opts.concurrency,
+        expect.any(Function),
+      );
+    });
     it('should add the given function to the queue handlers with name', () => {
       const instance = { handler: jest.fn() };
       const queue = { process: jest.fn() } as any;