diff options
Diffstat (limited to 'redis/client.py')
| -rw-r--r-- | redis/client.py | 9 |
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): |