35   auto checkpoint_name = "on_consumer_disconnect_" + std::to_string(i++);  in ~MockConsumer()  local
36   auto on_disconnect = task_runner_->CreateCheckpoint(checkpoint_name);  in ~MockConsumer()
39   task_runner_->RunUntilCheckpoint(checkpoint_name);  in ~MockConsumer()
45   auto checkpoint_name = "on_consumer_connect_" + std::to_string(i++);  in Connect()  local
46   auto on_connect = task_runner_->CreateCheckpoint(checkpoint_name);  in Connect()
48   task_runner_->RunUntilCheckpoint(checkpoint_name);  in Connect()
74   auto checkpoint_name = "on_tracing_disabled_consumer_" + std::to_string(i++);  in WaitForTracingDisabled()  local
75   auto on_tracing_disabled = task_runner_->CreateCheckpoint(checkpoint_name);  in WaitForTracingDisabled()
77   task_runner_->RunUntilCheckpoint(checkpoint_name, timeout_ms);  in WaitForTracingDisabled()
82   auto checkpoint_name = "on_consumer_flush_" + std::to_string(i++);  in Flush()  local
83   auto on_flush = task_runner_->CreateCheckpoint(checkpoint_name);  in Flush()
92                                     checkpoint_name]() -> bool {  in Flush()
93     task_runner->RunUntilCheckpoint(checkpoint_name);  in Flush()
103   std::string checkpoint_name = "on_read_buffers_" + std::to_string(i++);  in ReadBuffers()  local
104   auto on_read_buffers = task_runner_->CreateCheckpoint(checkpoint_name);  in ReadBuffers()
118   task_runner_->RunUntilCheckpoint(checkpoint_name);  in ReadBuffers()
128   auto checkpoint_name = "on_trace_stats_" + std::to_string(i++);  in WaitForTraceStats()  local
129   auto on_trace_stats = task_runner_->CreateCheckpoint(checkpoint_name);  in WaitForTraceStats()
142   task_runner_->RunUntilCheckpoint(checkpoint_name);  in WaitForTraceStats()
152   std::string checkpoint_name = "on_observable_events_" + std::to_string(i++);  in WaitForObservableEvents()  local
153   auto on_observable_events = task_runner_->CreateCheckpoint(checkpoint_name);  in WaitForObservableEvents()
160   task_runner_->RunUntilCheckpoint(checkpoint_name);  in WaitForObservableEvents()