googleapis
diff --git a/Collapse file
‎samples/snippets/subscriber.py‎
Copy file name to clipboardExpand all lines: samples/snippets/subscriber.py
+1-2Lines changed: 1 addition & 2 deletions b/Collapse file
‎samples/snippets/subscriber.py‎
Copy file name to clipboardExpand all lines: samples/snippets/subscriber.py
+1-2Lines changed: 1 addition & 2 deletions
@@ -124,9 +124,8 @@ def callback(message):
 
     # Blocks the thread while messages are coming in through the stream. Any
     # exceptions that crop up on the thread will be set on the future.
-    future = subscription.open(callback)
     try:
-        future.result()
+        subscription.future.result()
     except Exception as e:
         print(
             'Listening for messages on {} threw an Exception: {}.'.format(