fix sub mode

cokeeffekt · Mar 22, 2020 · 1a95ad0 · 1a95ad0
1 parent c4e491f
commit 1a95ad0
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/package.json b/package.json
@@ -1,6 +1,6 @@
 {
   "name": "snub",
-  "version": "2.0.3",
+  "version": "2.0.4",
   "description": "pub/sub",
   "main": "snub.js",
   "scripts": {

diff --git a/snub.js b/snub.js
@@ -113,7 +113,7 @@ module.exports = function (config) {
 
     eventsRegistered.push(ev);
     try {
-      await redis.psubscribe(prefix + pattern);
+      await sub.psubscribe(prefix + pattern);
     } catch (error) {
       console.log('Snub Error => ' + error);
       var evIndex = eventsRegistered.findIndex(e => e === ev);
@@ -130,7 +130,7 @@ module.exports = function (config) {
       .map(v => eventsRegistered.findIndex(f => f === v))
       .reverse().forEach(i => eventsRegistered.splice(i, 1));
     if (!eventsRegistered.find(e => e.pattern === pattern))
-      await redis.punsubscribe(prefix + pattern);
+      await sub.punsubscribe(prefix + pattern);
   };
 
   // send to one listener