-
Notifications
You must be signed in to change notification settings - Fork 374
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
feat(pubsub): implement per-call options for Subscriber
#10043
feat(pubsub): implement per-call options for Subscriber
#10043
Conversation
Google Cloud Build Logs
ℹ️ NOTE: Kokoro logs are linked from "Details" below. |
Codecov ReportBase: 94.22% // Head: 94.23% // Increases project coverage by
Additional details and impacted files@@ Coverage Diff @@
## main #10043 +/- ##
=======================================
Coverage 94.22% 94.23%
=======================================
Files 1525 1526 +1
Lines 141667 141758 +91
=======================================
+ Hits 133485 133582 +97
+ Misses 8182 8176 -6
Help us with your feedback. Take ten seconds to tell us how you rate us. Have a feature suggestion? Share it here. ☔ View full report at Codecov. |
Google Cloud Build Logs
ℹ️ NOTE: Kokoro logs are linked from "Details" below. |
Google Cloud Build Logs
ℹ️ NOTE: Kokoro logs are linked from "Details" below. |
Subscriber subscriber(mock, Options{}.set<TestOptionA>("override-a")); | ||
ASSERT_STATUS_OK(subscriber | ||
.Subscribe([](Message const&, AckHandler const&) {}, | ||
Options{}.set<TestOptionB>("override-b1")) |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Perhaps these should also be setting TestOptionA
too, to check that call overrides client.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Done
google/cloud/pubsub/subscriber.cc
Outdated
Subscriber::Subscriber(std::shared_ptr<SubscriberConnection> connection, | ||
Options opts) | ||
: connection_(std::move(connection)), | ||
options_(google::cloud::internal::MergeOptions(std::move(opts), |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Q. Do we like google::cloud::
qualifications when we're already in google::cloud
?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Fixed.
01f3d37
to
5942541
Compare
Google Cloud Build Logs
ℹ️ NOTE: Kokoro logs are linked from "Details" below. |
Part of the work for #7689
This change is