We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 58a7b94 commit 85ee346Copy full SHA for 85ee346
test/src/live_blocking_tests.cpp
@@ -331,7 +331,7 @@ TEST_F(LiveBlockingTests, TestStop) {
331
static_cast<::ssize_t>(rec_str.size())) {
332
}
333
}} // namespace test
334
- }; // namespace databento
+ }; // namespace databento
335
336
LiveBlocking target{
337
logger_.get(), kKey, dataset::kXnasItch, kLocalhost,
test/src/shared_channel_tests.cpp
@@ -30,9 +30,8 @@ class SharedChannelTests : public testing::Test {
30
};
31
32
TEST_F(SharedChannelTests, TestReadExact) {
33
- write_thread_ = ScopedThread{[this] {
34
- this->Write({"parse", "stream", "tests", "end"});
35
- }};
+ write_thread_ = ScopedThread{
+ [this] { this->Write({"parse", "stream", "tests", "end"}); }};
36
std::array<std::uint8_t, 16> buffer{};
37
target_.ReadExact(buffer.data(), 3);
38
EXPECT_STREQ(reinterpret_cast<const char*>(buffer.data()), "par");
@@ -70,9 +69,8 @@ TEST_F(SharedChannelTests, TestInterleavedReadsAndWrites) {
70
69
71
72
TEST_F(SharedChannelTests, TestReadSome) {
73
74
- this->Write({"parse", "stream", "tests", "some", "last"});
75
+ [this] { this->Write({"parse", "stream", "tests", "some", "last"}); }};
76
77
std::string res;
78
// -1 to keep last null byte
0 commit comments