diff --git a/rtc_base/task_queue_for_test.h b/rtc_base/task_queue_for_test.h index 7844dc4ad9..dd5679bc99 100644 --- a/rtc_base/task_queue_for_test.h +++ b/rtc_base/task_queue_for_test.h @@ -66,6 +66,14 @@ class RTC_LOCKABLE TaskQueueForTest : public rtc::TaskQueue { void SendTask(Closure&& task, rtc::Location loc) { ::webrtc::SendTask(loc, Get(), std::forward(task)); } + + // Wait for the completion of all tasks posted prior to the + // WaitForPreviouslyPostedTasks() call. + void WaitForPreviouslyPostedTasks() { + // Post an empty task on the queue and wait for it to finish, to ensure + // that all already posted tasks on the queue get executed. + SendTask([]() {}, RTC_FROM_HERE); + } }; } // namespace webrtc