Skip to content

Commit bcb1480

Browse files
FIX: Fix cpp smoke test
1 parent 09e4bf2 commit bcb1480

File tree

1 file changed

+4
-6
lines changed

1 file changed

+4
-6
lines changed

examples/live/live_smoke_test.cpp

Lines changed: 4 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -53,7 +53,7 @@ void ProcessRecords(db::LiveBlocking& client, db::Schema schema,
5353

5454
while (auto record = client.NextRecord(timeout)) {
5555
if (record->RType() == expected_rtype) {
56-
std::cout << "Received expected record type " << expected_rtype << '\n';
56+
std::cout << "Received expected record type \n";
5757
break;
5858
} else if (auto* msg = record->GetIf<db::ErrorMsg>()) {
5959
std::stringstream ss;
@@ -66,13 +66,11 @@ void ProcessRecords(db::LiveBlocking& client, db::Schema schema,
6666
std::cout << "Finished client\n";
6767
}
6868

69-
void ProcessSnapshotRecords(db::LiveBlocking& client, db::Schema schema) {
69+
void ProcessSnapshotRecords(db::LiveBlocking& client) {
7070
client.Start();
7171

7272
std::cout << "Starting client...\n";
7373

74-
const auto expected_rtype = db::Record::RTypeFromSchema(schema);
75-
7674
constexpr auto timeout = std::chrono::seconds{30};
7775

7876
auto received_snapshot_record = false;
@@ -82,7 +80,7 @@ void ProcessSnapshotRecords(db::LiveBlocking& client, db::Schema schema) {
8280
if (mbo_msg->flags.IsSnapshot()) {
8381
received_snapshot_record = true;
8482
} else {
85-
std::cout << "Received expected record type " << expected_rtype << '\n';
83+
std::cout << "Received expected record type\n";
8684
break;
8785
}
8886
} else if (auto* error_msg = record->GetIf<db::ErrorMsg>()) {
@@ -195,7 +193,7 @@ int main(int argc, char* argv[]) {
195193
}
196194

197195
if (use_snapshot) {
198-
ProcessSnapshotRecords(client, schema);
196+
ProcessSnapshotRecords(client);
199197
} else {
200198
ProcessRecords(client, schema, start_from_epoch);
201199
}

0 commit comments

Comments
 (0)