From 12579e5e8e7f992f99c7ee36e12214256d27c017 Mon Sep 17 00:00:00 2001
From: Ruben Bridgewater <ruben.bridgewater@fintura.de>
Date: Sat, 26 Mar 2016 04:53:27 +0100
Subject: [PATCH] Test pubsub numsub

Closes #740
---
 test/pubsub.spec.js | 18 +++++++++++-------
 1 file changed, 11 insertions(+), 7 deletions(-)

diff --git a/test/pubsub.spec.js b/test/pubsub.spec.js
index 2e54e8e883..cefe33f5d0 100644
--- a/test/pubsub.spec.js
+++ b/test/pubsub.spec.js
@@ -477,19 +477,23 @@ describe("publish/subscribe", function () {
 
             describe('psubscribe', function () {
                 it('allows all channels to be subscribed to using a * pattern', function (done) {
-                    sub.end(false);
-                    sub = redis.createClient({
+                    sub.subscribe('/foo');
+                    var sub2 = redis.createClient({
                         return_buffers: true
                     });
-                    sub.on('ready', function () {
-                        sub.psubscribe('*');
-                        sub.on("pmessage", function(pattern, channel, message) {
+                    sub2.on('ready', function () {
+                        sub2.psubscribe('*');
+                        sub2.subscribe('/foo');
+                        sub2.on("pmessage", function(pattern, channel, message) {
                             assert.strictEqual(pattern.inspect(), new Buffer('*').inspect());
                             assert.strictEqual(channel.inspect(), new Buffer('/foo').inspect());
                             assert.strictEqual(message.inspect(), new Buffer('hello world').inspect());
-                            done();
+                            sub2.quit(done);
                         });
-                        pub.publish('/foo', 'hello world');
+                        pub.pubsub('numsub', '/foo', function (err, res) {
+                            assert.deepEqual(res, ['/foo', 2]);
+                        });
+                        pub.publish('/foo', 'hello world', helper.isNumber(3));
                     });
                 });
             });