Searched refs:tx_task_runner (Results 1 – 1 of 1) sorted by relevance
309 TestTaskRunner tx_task_runner; in TEST_F() local312 UnixSocket::Connect(kTestSocket.name(), &tx_events, &tx_task_runner, in TEST_F()315 auto cli_connected = tx_task_runner.CreateCheckpoint("cli_connected"); in TEST_F()318 tx_task_runner.RunUntilCheckpoint("cli_connected"); in TEST_F()320 auto all_sent = tx_task_runner.CreateCheckpoint("all_sent"); in TEST_F()322 tx_task_runner.PostTask([&cli, &buf, all_sent] { in TEST_F()327 tx_task_runner.RunUntilCheckpoint("all_sent", kTimeoutMs); in TEST_F()359 TestTaskRunner tx_task_runner; in TEST_F() local362 UnixSocket::Connect(kTestSocket.name(), &tx_events, &tx_task_runner, in TEST_F()365 auto cli_connected = tx_task_runner.CreateCheckpoint("cli_connected"); in TEST_F()[all …]