Searched refs:RunSynchronous (Results 1 – 7 of 7) sorted by relevance
219 worker_queue_.RunSynchronous([&] { in TEST_F()235 worker_queue_.RunSynchronous([&] { vss_impl->StartPerRtpStream({true}); }); in TEST_F()289 worker_queue_.RunSynchronous([&] { vss_impl->Stop(); }); in TEST_F()301 worker_queue_.RunSynchronous([&] { vss_impl->StartPerRtpStream({true}); }); in TEST_F()355 worker_queue_.RunSynchronous([&] { vss_impl->Stop(); }); in TEST_F()367 worker_queue_.RunSynchronous([&] { vss_impl->StartPerRtpStream({true}); }); in TEST_F()416 worker_queue_.RunSynchronous([&] { vss_impl->Stop(); }); in TEST_F()431 worker_queue_.RunSynchronous([&] { in TEST_F()442 worker_queue_.RunSynchronous([&] { in TEST_F()457 worker_queue_.RunSynchronous([&] { vss_impl->StartPerRtpStream({true}); }); in TEST_F()[all …]
323 rtp_transport_queue_->RunSynchronous( in StopPermanentlyAndGetRtpStates()
64 m.RunSynchronous([&] { in TEST()78 m.RunSynchronous([&] { in TEST()121 m.RunSynchronous([&] { EXPECT_TRUE(m.IsCurrent()); }); in TEST()
53 void RunSynchronous(absl::AnyInvocable<void() &&> task);
49 void MaybeWorkerThread::RunSynchronous(absl::AnyInvocable<void() &&> task) { in RunSynchronous() function in webrtc::MaybeWorkerThread
639 helper.worker()->RunSynchronous( in TEST()656 helper.worker()->RunSynchronous( in TEST()673 helper.worker()->RunSynchronous( in TEST()690 helper.worker()->RunSynchronous( in TEST()711 helper.worker()->RunSynchronous( in TEST()732 helper.worker()->RunSynchronous( in TEST()753 helper.worker()->RunSynchronous( in TEST()772 helper.worker()->RunSynchronous( in TEST()875 helper.worker()->RunSynchronous( in TEST()884 helper.worker()->RunSynchronous( in TEST()[all …]
188 rtp_transport_queue_->RunSynchronous([] {}); in ~AudioSendStream()869 rtp_transport_queue_->RunSynchronous([this] { in RemoveBitrateObserver()