Home
last modified time | relevance | path

Searched refs:drain_queue (Results 1 – 3 of 3) sorted by relevance

/external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/operators/
Drx-observe_on.hpp85 mutable queue_type drain_queue; member
108 swap(drain_expired, drain_queue); in finish()
122 if (!lifetime.is_subscribed() && fill_queue.empty() && drain_queue.empty()) { in ensure_processing()
132 if (drain_queue.empty() || !destination.is_subscribed()) { in ensure_processing()
135 … (!lifetime.is_subscribed() && fill_queue.empty() && drain_queue.empty())) { in ensure_processing()
139 if (drain_queue.empty()) { in ensure_processing()
144 swap(fill_queue, drain_queue); in ensure_processing()
147 auto notification = std::move(drain_queue.front()); in ensure_processing()
148 drain_queue.pop_front(); in ensure_processing()
/external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/subjects/
Drx-synchronize.hpp58 auto drain_queue = [keepAlive, this](const rxsc::schedulable& self){ in ensure_processing() local
85 [&](){return coordinator.act(drain_queue);}, in ensure_processing()
/external/linux-kselftest/tools/testing/selftests/mqueue/
Dmq_perf_tests.c337 #define drain_queue() \ macro
512 drain_queue(); in perf_test_thread()