Module subscriber.futures (2.1.0)

API documentation for pubsub_v1.subscriber.futures module.

Classes

StreamingPullFuture

StreamingPullFuture(manager)

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.