We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent fb0da4c commit 1bfa445Copy full SHA for 1bfa445
pubsub/cloud-client/subscriber.py
@@ -124,9 +124,8 @@ def callback(message):
124
125
# Blocks the thread while messages are coming in through the stream. Any
126
# exceptions that crop up on the thread will be set on the future.
127
- future = subscription.open(callback)
128
try:
129
- future.result()
+ subscription.future.result()
130
except Exception as e:
131
print(
132
'Listening for messages on {} threw an Exception: {}.'.format(
0 commit comments