-
Notifications
You must be signed in to change notification settings - Fork 230
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
Samples to use async/await #305
Conversation
Codecov Report
@@ Coverage Diff @@
## master #305 +/- ##
========================================
Coverage ? 96.4%
========================================
Files ? 13
Lines ? 1057
Branches ? 143
========================================
Hits ? 1019
Misses ? 32
Partials ? 6 Continue to review full report at Codecov.
|
samples/subscriptions.js
Outdated
// setInterval() gets run every 10s. | ||
const interval = setInterval(function() { | ||
// Every 10s, we do a check on the processing states of the messages. | ||
Object.keys(messages).forEach(async ackId => { |
This comment was marked as spam.
This comment was marked as spam.
Sorry, something went wrong.
samples/subscriptions.js
Outdated
// Pub/Sub messages are unordered, so here we manually order messages by | ||
// their "counterId" attribute which was set when they were published. | ||
const outstandingIds = Object.keys(outstandingMessages).map(counterId => | ||
parseInt(counterId, 10) |
This comment was marked as spam.
This comment was marked as spam.
Sorry, something went wrong.
👋 This has a lot of merge conflicts now :/ Apologies! |
Works towards googleapis/google-cloud-node#2865 and googleapis/google-cloud-node#2869 (it's a good idea to open an issue first for discussion)