v0.35.3

Implementation Changes

• Add additional error handling to unary RPCs (#5438)

v0.35.2

Implementation Changes

• Add heartbeating to the streaming pull manager (#5413)
• Fix retrying of bidirectional RPCs and closing the streaming pull manager (#5412)

v0.35.1: Release pubsub 0.35.1 (#5404)

Implementation Changes

• Catch errors when re-retying send() or recv() in addition to open() (#5402)

v0.35.0

Implementation Changes

• Send requests during streaming pull over a separate unary RPC (#5377)
• Initialize references to helper threads before starting them (#5374)
• Make leaser exit more quickly (#5373
• Make re-open failures bubble to callbacks (#5372)
• Avoid overwriting 'module' of messages from shared modules. (#5364)
• Normalize overflow handling for max count and bytes (#5343)

New Features

• Restore the synchronous pull method (#5379)
• Promote subscribe_experimental() to subscribe(), remove old subscriber implementation. (#5274)
• Wire up scheduler argument for subscribe() (#5279)

Documentation

• Add link to streaming pull behavior documentation (#5378)
• Fix example in subscribe's documentation (#5375)

Internal / Testing Changes

• Add Test runs for Python 3.7 and remove 3.4 (#5295)
• Modify system tests to use prerelease versions of grpcio (#5304)

v0.34.0

Implementation Changes

• Lower the flow control defaults. (#5248)

New Features

• A new implementation of the subscriber has been added. This is available as SubscriberClient.subscribe_experimental. In the next release, this will be replace the current subscribe method. If you use this, please report your
  findings to us on GitHub. (#5189, #5201, #5210, #5229, #5230, #5237, #5256)

Dependencies

• Remove psutil dependency. (#5248)

v0.33.1

Implementation changes

• Surface publish RPC errors back to the publish futures (#5124)
• Make the pausable response iterator aware of the RPC state to prevent deadlock (#5108)
• Properly handle graceful stop in request generator (#5097)

v0.33.0

Implementation changes

• Drop leased messages after flow_control.max_lease_duration has passed. (#5020)
• Fix mantain leases to not modack messages it just dropped (#5045)
• Avoid race condition in maintain_leases by copying leased_messages (#5035)
• Retry subscription stream on InternalServerError, Unknown, and GatewayTimeout (#5021)
• Use the rpc's status to determine when to exit the request generator thread (#5054)
• Fix missing iter on request stream (#5078)
• Nack messages when the subscriber callback errors (#5019)

Testing

• pubsub nox.py cleanup (#5056)
• Fix test that checks for retryable exceptions (#5034)

v0.32.1

Dependencies

• Update dependency range for api-core to include v1.0.0 releases (#4944)

Testing and internal changes

• Install local dependencies when running lint (#4936)
• Re-enable lint for tests, remove usage of pylint (#4921)

v0.32.0

Implementation changes

• Added support for streaming pull receipts. (#4878)

v0.31.0

New features

• Added the ability for subscriber to batch requests. (#4895)
• Added pending request backpressure for subscriber. (#4892)

Implementation changes

• Raise ValueError when a message is too large for a batch. (#4872)
• Updated the default batch size to 10 MB. (#4857)
• Allow a custom Event type in Pub / Sub futures. (#4643)

Documentation

• Clarify that modify_ack_deadline resets the deadline. (#4822)

Testing

• Fix unit test for default max_bytes value. (#4860)