-
Notifications
You must be signed in to change notification settings - Fork 1.1k
Fix PubSub Iterator pullAsync: add callback to PubSubRpc.pull #1048
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Conversation
|
/cc @aozarov |
| } | ||
| } | ||
|
|
||
| private static final class PullFutureImpl implements PullFuture { |
This comment was marked as spam.
This comment was marked as spam.
Sorry, something went wrong.
This comment was marked as spam.
This comment was marked as spam.
Sorry, something went wrong.
|
Looks good to me. I didn't look at the tests or the doc changes. I will let @lesv do that. |
|
Comment fixed. @lesv ready if you want to have al look. |
|
Comments look fine |
…telligence to v2.2.13 (#1048) [](https://renovatebot.com) This PR contains the following updates: | Package | Change | Age | Adoption | Passing | Confidence | |---|---|---|---|---|---| | [com.google.cloud:google-cloud-video-intelligence](https://togithub.com/googleapis/java-video-intelligence) | `2.2.12` -> `2.2.13` | [](https://docs.renovatebot.com/merge-confidence/) | [](https://docs.renovatebot.com/merge-confidence/) | [](https://docs.renovatebot.com/merge-confidence/) | [](https://docs.renovatebot.com/merge-confidence/) | --- ### Configuration 📅 **Schedule**: Branch creation - At any time (no schedule defined), Automerge - At any time (no schedule defined). 🚦 **Automerge**: Disabled by config. Please merge this manually once you are satisfied. ♻ **Rebasing**: Renovate will not automatically rebase this PR, because other commits have been found. 🔕 **Ignore**: Close this PR and you won't be reminded about this update again. --- - [ ] <!-- rebase-check -->If you want to rebase/retry this PR, click this checkbox. ⚠ **Warning**: custom changes will be lost. --- This PR has been generated by [Mend Renovate](https://www.mend.io/free-developer-tools/renovate/). View repository job log [here](https://app.renovatebot.com/dashboard#github/googleapis/java-video-intelligence). <!--renovate-debug:eyJjcmVhdGVkSW5WZXIiOiIzMi4yMjIuMyIsInVwZGF0ZWRJblZlciI6IjMyLjIyMi4zIn0=-->
…to v3.10.5 (#1048) [](https://renovatebot.com) This PR contains the following updates: | Package | Change | Age | Adoption | Passing | Confidence | |---|---|---|---|---|---| | [com.google.cloud:google-cloud-logging](https://togithub.com/googleapis/java-logging) | `3.10.4` -> `3.10.5` | [](https://docs.renovatebot.com/merge-confidence/) | [](https://docs.renovatebot.com/merge-confidence/) | [](https://docs.renovatebot.com/merge-confidence/) | [](https://docs.renovatebot.com/merge-confidence/) | --- ### Release Notes <details> <summary>googleapis/java-logging</summary> ### [`v3.10.5`](https://togithub.com/googleapis/java-logging/blob/HEAD/CHANGELOG.md#​3105-httpsgithubcomgoogleapisjava-loggingcomparev3104v3105-2022-08-25) [Compare Source](https://togithub.com/googleapis/java-logging/compare/v3.10.4...v3.10.5) ##### Bug Fixes - resource detection for 2nd gen of Cloud Functions works incorrectly ([#​1045](https://togithub.com/googleapis/java-logging/issues/1045)) ([dda1d0a](https://togithub.com/googleapis/java-logging/commit/dda1d0a48c3db18b46b8306c3304a79054e9b49c)) </details> --- ### Configuration 📅 **Schedule**: Branch creation - At any time (no schedule defined), Automerge - At any time (no schedule defined). 🚦 **Automerge**: Disabled by config. Please merge this manually once you are satisfied. ♻ **Rebasing**: Whenever PR becomes conflicted, or you tick the rebase/retry checkbox. 🔕 **Ignore**: Close this PR and you won't be reminded about this update again. --- - [ ] <!-- rebase-check -->If you want to rebase/retry this PR, click this checkbox. --- This PR has been generated by [Mend Renovate](https://www.mend.io/free-developer-tools/renovate/). View repository job log [here](https://app.renovatebot.com/dashboard#github/googleapis/java-logging). <!--renovate-debug:eyJjcmVhdGVkSW5WZXIiOiIzMi4xNzYuMCIsInVwZGF0ZWRJblZlciI6IjMyLjE3Ni4wIn0=-->
This PR follows from the discussion in #1041 and fixes
Future<Iterator<ReceivedMessage>> pullAsync.PubSubRpc.pullchanges signature toPullFuture pull(String).PullFutureextendsFuture<PullResponse>and allows to register callbacks to the RPC's future so messages can be added to the ack deadline renewer as soon as pulled.