Make pubsub.subscribe work.

This commit is contained in:
Luke Sneeringer
2014-11-04 11:16:53 -06:00
parent fd9647ce94
commit 8346f68f2c

View File

@@ -103,7 +103,7 @@ class PubSub(object):
if message is None:
time.sleep(max(wait, 0.001))
else:
yield json.loads(message)
yield json.loads(message['data'])
def close(self):
"""Close the pubsub connection."""