Add option for disabling fan out

Author: Marvel Mathew

lib/index.js

@@ -39,8 +39,9 @@ class Publisher {
 
 class Subscriber extends events.EventEmitter {
 
-  constructor() {
+  constructor(options) {
     super();
+    this.disableFanOut = options.disableFanOut || false;
   }
 
   subscribe(channel) {
@@ -72,9 +73,13 @@ class Subscriber extends events.EventEmitter {
   }
 
   _createSubscription(topic, channel) {
-
-    const subscriptionUUID = uuid.v1();
-    var subscriptionName = `${namePrefix}-${channel}-${subscriptionUUID}`;
+    let subscriptionName;
+    if (!this.disableFanOut) {
+      const subscriptionUUID = uuid.v1();
+      subscriptionName = `${namePrefix}-${channel}-${subscriptionUUID}`;
+    } else {
+      subscriptionName = `${namePrefix}-${channel}`;
+    }
 
     topic.subscribe(subscriptionName, (err, subscription) => {
 
@@ -140,8 +145,8 @@ function createPublisher() {
   return new Publisher(emitter);
 }
 
-function createSubscriber() {
-  return new Subscriber();
+function createSubscriber(options) {
+  return new Subscriber(options);
 }
 
 module.exports = {