Searched refs:tx_task_runner (Results 1 – 1 of 1) sorted by relevance
323 TestTaskRunner tx_task_runner; in TEST_F() local326 UnixSocket::Connect(kTestSocket.name(), &tx_events, &tx_task_runner, in TEST_F()329 auto cli_connected = tx_task_runner.CreateCheckpoint("cli_connected"); in TEST_F()332 tx_task_runner.RunUntilCheckpoint("cli_connected"); in TEST_F()334 auto all_sent = tx_task_runner.CreateCheckpoint("all_sent"); in TEST_F()336 tx_task_runner.PostTask([&cli, &buf, all_sent] { in TEST_F()341 tx_task_runner.RunUntilCheckpoint("all_sent", kTimeoutMs); in TEST_F()373 TestTaskRunner tx_task_runner; in TEST_F() local376 UnixSocket::Connect(kTestSocket.name(), &tx_events, &tx_task_runner, in TEST_F()379 auto cli_connected = tx_task_runner.CreateCheckpoint("cli_connected"); in TEST_F()[all …]