feat(EventBus): Support publish multiple events (array) in event bus.

README.md

@@ -268,6 +268,12 @@ When submitting your pull-request try to follow those guides:
 
 All notable changes to this project will be documented in this section.
 
+### 0.2.0
+
+#### Added
+
+- Support publish multiple events (array) in event bus.
+
 ### 0.1.0
 
 #### Added

package.json

@@ -1,6 +1,6 @@
 {
   "name": "curli-bus",
-  "version": "0.1.0-beta.1",
+  "version": "0.2.0-beta.0",
   "description": "Simple Command Bus Implementation (CQRS) for NodeJS/Typescript.",
   "main": "index",
   "scripts": {

src/EventBus/EventBus.ts

@@ -23,10 +23,20 @@ export class EventBus {
     }
 
     /**
-     * Publish an event
-     * @param {Event} event
+     * Publish an event or a list of events.
+     * @param {Event|Array<Event>} event
      */
-    public publish(event: Event): void {
+    public publish(events: Event | Array<Event>): void {
+        if (Array.isArray(events)) {
+            events.forEach((event: Event) => {
+                this.publishSingleEvent(event);
+            });
+        } else {
+            this.publishSingleEvent(events);
+        }
+    }
+
+    public publishSingleEvent(event: Event): void {
 
         if (!this.subscribersMap.hasOwnProperty(event.eventName)) {
             throw new Error(`There is not a subscriber for ${event.eventName} event.`);

src/__tests__/unit/EventBus.test.ts

@@ -41,6 +41,35 @@ describe('EventBus class tests', function () {
         const event = new EventTest({name: 'carlos'});
         eventBus.publish(event);
     });
+
+    it('Should publish a list of events', function () {
+        const subscriber = new EventSubscriber();
+        let checkTimesCallEventCarlos = 0;
+        let checkTimesCallEventMiguel = 0;
+
+        subscriber.handle = (event: Event) => {
+            if ('carlos' === event.data.name) {
+                checkTimesCallEventCarlos++;
+            } else if ('miguel' === event.data.name) {
+                checkTimesCallEventMiguel++;
+            }
+        };
+
+        eventBus.register(subscriber);
+
+        const event1 = new EventTest({name: 'carlos'});
+        const event2 = new EventTest({name: 'carlos'});
+        const event3 = new EventTest({name: 'carlos'});
+        const event4 = new EventTest({name: 'miguel'});
+
+        const eventsList: Array<Event> = [event1, event2, event3, event4];
+
+        eventBus.publish(eventsList);
+
+        chai.assert.deepEqual(3, checkTimesCallEventCarlos);
+        chai.assert.deepEqual(1, checkTimesCallEventMiguel);
+    });
+
     it('Should publish an event wit a few subscribers', function () {
         const subscriber1 = new EventSubscriber();
         const subscriber2 = new EventSubscriber();