Small change to pubsub, hopefully fixing #49, or at least making it a little more sane

1 files changed, 7 insertions, 2 deletions

diff --git a/redis/client.py b/redis/client.py
index 6405947..41a9660 100644
--- a/redis/client.py
+++ b/redis/client.py
@@ -1203,10 +1203,15 @@ class Redis(threading.local):
                 'data': r[3]
                 }
             else:
-                msg = {'type': r[0], 'channel': r[1], 'data': r[2]}
-            yield msg
+                msg = {
+                'type': r[0],
+                'pattern': None,
+                'channel': r[1],
+                'data': r[2]
+                }
             if r[0] == 'unsubscribe' and r[2] == 0:
                 self.subscribed = False
+            yield msg
 
 
 class Pipeline(Redis):