Searched refs:fill_queue (Results 1 – 2 of 2) sorted by relevance
44 mutable queue_type fill_queue; member63 fill_queue.clear(); in ensure_processing()68 if (fill_queue.empty()) { in ensure_processing()72 auto notification = std::move(fill_queue.front()); in ensure_processing()73 fill_queue.pop_front(); in ensure_processing()108 fill_queue.push_back(notification_type::on_next(std::move(v))); in on_next()116 fill_queue.push_back(notification_type::on_error(e)); in on_error()124 fill_queue.push_back(notification_type::on_completed()); in on_completed()
84 mutable queue_type fill_queue; member106 swap(fill_expired, fill_queue); in finish()122 if (!lifetime.is_subscribed() && fill_queue.empty() && drain_queue.empty()) { in ensure_processing()135 … (!lifetime.is_subscribed() && fill_queue.empty() && drain_queue.empty())) { in ensure_processing()140 if (fill_queue.empty()) { in ensure_processing()144 swap(fill_queue, drain_queue); in ensure_processing()189 state->fill_queue.push_back(notification_type::on_next(std::move(v))); in on_next()195 state->fill_queue.push_back(notification_type::on_error(e)); in on_error()201 state->fill_queue.push_back(notification_type::on_completed()); in on_completed()