Skip to content

Navigation Menu

Sign in
Appearance settings

Search code, repositories, users, issues, pull requests...

Provide feedback

We read every piece of feedback, and take your input very seriously.

Saved searches

Use saved searches to filter your results more quickly

Appearance settings

feat: implement Flow control batcher - #15

#15
Merged
dpcollins-google merged 6 commits into
mastergoogleapis/python-pubsublite:masterfrom
flow_control_batchergoogleapis/python-pubsublite:flow_control_batcherCopy head branch name to clipboard
Sep 15, 2020
Merged

feat: implement Flow control batcher#15
dpcollins-google merged 6 commits into
mastergoogleapis/python-pubsublite:masterfrom
flow_control_batchergoogleapis/python-pubsublite:flow_control_batcherCopy head branch name to clipboard

Conversation

@dpcollins-google

Copy link
Copy Markdown
Contributor

This handles aggregating flow control requests without allowing them to get above the max int64 value.

@google-cla google-cla Bot added the cla: yes This human has signed the Contributor License Agreement. label Sep 10, 2020
Also small fix to retrying connection so it doesn't leak reads/writes from previous connections.
…nments.

Also slightly change the semantics of PermanentFailable to not fail a RetryingConnection on retryable errors from a watched awaitable.
This handles aggregating flow control requests without allowing them to get above the max int64 value.
@dpcollins-google
dpcollins-google requested review from a team and pradn September 15, 2020 20:30
@dpcollins-google
dpcollins-google merged commit 0a09bb3 into master Sep 15, 2020
@anguillanneuf
anguillanneuf deleted the flow_control_batcher branch March 25, 2022 22:36
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

cla: yes This human has signed the Contributor License Agreement.

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants

Morty Proxy This is a proxified and sanitized view of the page, visit original site.