Skip to content

Commit 4b4726c

Browse files
committed
address review comments
1 parent 480d034 commit 4b4726c

1 file changed

Lines changed: 2 additions & 3 deletions

File tree

google/cloud/pubsub/publisher_connection.cc

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -138,13 +138,12 @@ std::shared_ptr<pubsub::PublisherConnection> MakePublisherConnection(
138138
if (options.message_ordering()) {
139139
auto factory = [topic, options, sink, cq](std::string const& key) {
140140
return BatchingPublisherConnection::Create(
141-
std::move(topic), std::move(options), key,
142-
SequentialBatchSink::Create(std::move(sink)), std::move(cq));
141+
topic, options, key, SequentialBatchSink::Create(sink), cq);
143142
};
144143
return OrderingKeyPublisherConnection::Create(std::move(factory));
145144
}
146145
return RejectsWithOrderingKey::Create(BatchingPublisherConnection::Create(
147-
topic, options, {}, std::move(sink), std::move(cq)));
146+
std::move(topic), options, {}, std::move(sink), std::move(cq)));
148147
};
149148
auto connection = make_connection();
150149
if (options.full_publisher_rejects() || options.full_publisher_blocks()) {

0 commit comments

Comments
 (0)