Searched refs:ensure_processing (Results 1 – 2 of 2) sorted by relevance
115 void ensure_processing(std::unique_lock<std::mutex>& guard) const { in ensure_processing() function190 state->ensure_processing(guard); in on_next()196 state->ensure_processing(guard); in on_error()202 state->ensure_processing(guard); in on_completed()213 keepAlive->ensure_processing(guard); in make()
50 void ensure_processing(std::unique_lock<std::mutex>& guard) const { in ensure_processing() function109 ensure_processing(guard); in on_next()117 ensure_processing(guard); in on_error()125 ensure_processing(guard); in on_completed()