Skip to content

Commit 5f2058e

Browse files
committed
code format
1 parent 038ca5d commit 5f2058e

File tree

1 file changed

+6
-6
lines changed

1 file changed

+6
-6
lines changed

tests/ConsumerTest.cc

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -1543,11 +1543,12 @@ TEST(ConsumerTest, testConsumerListenerShouldNotSegfaultAfterClose) {
15431543
consumerConfig.setSubscriptionInitialPosition(InitialPositionEarliest);
15441544
Latch latchFirstReceiveMsg(1);
15451545
Latch latchAfterClosed(1);
1546-
consumerConfig.setMessageListener([&latchFirstReceiveMsg, &latchAfterClosed](Consumer consumer, const Message& msg) {
1547-
latchFirstReceiveMsg.countdown();
1548-
std::cout << "Consume message: " << msg.getDataAsString() << std::endl;
1549-
latchAfterClosed.wait();
1550-
});
1546+
consumerConfig.setMessageListener(
1547+
[&latchFirstReceiveMsg, &latchAfterClosed](Consumer consumer, const Message& msg) {
1548+
latchFirstReceiveMsg.countdown();
1549+
std::cout << "Consume message: " << msg.getDataAsString() << std::endl;
1550+
latchAfterClosed.wait();
1551+
});
15511552
auto result = client.subscribe(topicName, "test-sub", consumerConfig, consumer);
15521553
ASSERT_EQ(ResultOk, result);
15531554

@@ -1560,5 +1561,4 @@ TEST(ConsumerTest, testConsumerListenerShouldNotSegfaultAfterClose) {
15601561
ASSERT_EQ(ResultOk, client.close());
15611562
}
15621563

1563-
15641564
} // namespace pulsar

0 commit comments

Comments
 (0)