Module subscriber.futures (2.21.1)

Version latest

• 2.21.1 (latest)
• 2.21.0
• 2.20.3
• 2.19.8
• 2.18.4
• 2.17.1
• 2.16.1
• 2.15.2
• 2.14.1
• 2.13.12
• 2.12.1
• 2.11.1
• 2.10.0
• 2.9.0
• 2.8.0
• 2.7.1
• 2.6.1
• 2.5.0
• 2.4.2
• 2.3.0
• 2.2.0
• 2.1.0
• 2.0.0
• 1.7.2
• 1.6.1
• 1.5.0
• 1.4.3
• 1.3.1
• 1.2.0
• 1.1.0
• 1.0.2
• 0.45.0
• 0.44.0
• 0.43.0

API documentation for pubsub_v1.subscriber.futures module.

Classes

Future

Future()

This future object is for subscribe-side calls.

Calling result will resolve the future by returning the message ID, unless an error occurs.

StreamingPullFuture

StreamingPullFuture(manager: StreamingPullManager)

Represents a process that asynchronously performs streaming pull and schedules messages to be processed.

This future is resolved when the process is stopped (via cancel) or if it encounters an unrecoverable error. Calling .result() will cause the calling thread to block indefinitely.