Skip to content

Commit 0ffad7b

Browse files
committed
Fix format
1 parent abba991 commit 0ffad7b

File tree

2 files changed

+5
-7
lines changed

2 files changed

+5
-7
lines changed

lib/ChunkMessageIdImpl.h

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -38,12 +38,12 @@ class ChunkMessageIdImpl : public MessageIdImpl, public std::enable_shared_from_
3838
this->partition_ = lastChunkMsgId.partition();
3939
}
4040

41-
std::shared_ptr<const MessageIdImpl> getFirstChunkMessageId() const { return chunkedMessageIds_.front().impl_; }
42-
43-
std::vector<MessageId> moveChunkedMessageIds() noexcept {
44-
return std::move(chunkedMessageIds_);
41+
std::shared_ptr<const MessageIdImpl> getFirstChunkMessageId() const {
42+
return chunkedMessageIds_.front().impl_;
4543
}
4644

45+
std::vector<MessageId> moveChunkedMessageIds() noexcept { return std::move(chunkedMessageIds_); }
46+
4747
MessageId build() { return MessageId{std::dynamic_pointer_cast<MessageIdImpl>(shared_from_this())}; }
4848

4949
private:

lib/ConsumerImpl.h

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -270,9 +270,7 @@ class ConsumerImpl : public ConsumerImplBase {
270270

271271
const std::vector<MessageId>& getChunkedMessageIds() const noexcept { return chunkedMessageIds_; }
272272

273-
std::vector<MessageId> moveChunkedMessageIds() noexcept {
274-
return std::move(chunkedMessageIds_);
275-
}
273+
std::vector<MessageId> moveChunkedMessageIds() noexcept { return std::move(chunkedMessageIds_); }
276274

277275
long getReceivedTimeMs() const noexcept { return receivedTimeMs_; }
278276

0 commit comments

Comments
 (0)