Skip to content

Commit a6f80dc

Browse files
committed
Address review comments
1 parent 156cc88 commit a6f80dc

2 files changed

Lines changed: 4 additions & 14 deletions

File tree

google/cloud/pubsub/integration_tests/subscriber_integration_test.cc

Lines changed: 3 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -457,8 +457,7 @@ TEST_F(SubscriberIntegrationTest, PublishOrdered) {
457457

458458
TEST_F(SubscriberIntegrationTest, UnifiedCredentials) {
459459
auto options =
460-
google::cloud::Options{}.set<google::cloud::UnifiedCredentialsOption>(
461-
google::cloud::MakeGoogleDefaultCredentials());
460+
Options{}.set<UnifiedCredentialsOption>(MakeGoogleDefaultCredentials());
462461
auto const using_emulator =
463462
internal::GetEnv("PUBSUB_EMULATOR_HOST").has_value();
464463
if (using_emulator) {
@@ -473,18 +472,9 @@ TEST_F(SubscriberIntegrationTest, UnifiedCredentials) {
473472
}
474473

475474
TEST_F(SubscriberIntegrationTest, ExactlyOnce) {
476-
auto options = Options{}.set<google::cloud::UnifiedCredentialsOption>(
477-
MakeGoogleDefaultCredentials());
478-
auto const using_emulator =
479-
internal::GetEnv("PUBSUB_EMULATOR_HOST").has_value();
480-
if (using_emulator) {
481-
options = Options{}
482-
.set<UnifiedCredentialsOption>(MakeInsecureCredentials())
483-
.set<internal::UseInsecureChannelOption>(true);
484-
}
485-
auto publisher = Publisher(MakePublisherConnection(topic_, options));
475+
auto publisher = Publisher(MakePublisherConnection(topic_));
486476
auto subscriber =
487-
Subscriber(MakeSubscriberConnection(exactly_once_subscription_, options));
477+
Subscriber(MakeSubscriberConnection(exactly_once_subscription_));
488478

489479
std::mutex mu;
490480
std::map<std::string, int> ids;

google/cloud/pubsub/subscriber_connection.h

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -75,7 +75,7 @@ class SubscriberConnection {
7575
* `Subscriber::Subscribe(ExactlyOnceApplicationCallback)`.
7676
*
7777
* We use a different name for this function (as opposed to an overload) to
78-
* simplify the use is mocks.
78+
* simplify the use of mocks.
7979
*/
8080
virtual future<Status> ExactlyOnceSubscribe(ExactlyOnceSubscribeParams p);
8181
};

0 commit comments

Comments
 (0)