Searched refs:selectedWork (Results 1 – 9 of 9) sorted by relevance
136 auto selectedWork = on_exception( in timeout_observer() local139 if (selectedWork.empty()) { in timeout_observer()142 localState->worker.schedule(selectedWork.get()); in timeout_observer()172 auto selectedWork = on_exception( in on_next() local175 if (selectedWork.empty()) { in on_next()178 localState->worker.schedule(selectedWork.get()); in on_next()186 auto selectedWork = on_exception( in on_error() local189 if (selectedWork.empty()) { in on_error()192 localState->worker.schedule(selectedWork.get()); in on_error()200 auto selectedWork = on_exception( in on_completed() local[all …]
144 auto selectedWork = on_exception( in on_next() local147 if (selectedWork.empty()) { in on_next()150 localState->worker.schedule(selectedWork.get()); in on_next()158 auto selectedWork = on_exception( in on_error() local161 if (selectedWork.empty()) { in on_error()164 localState->worker.schedule(selectedWork.get()); in on_error()172 auto selectedWork = on_exception( in on_completed() local175 if (selectedWork.empty()) { in on_completed()178 localState->worker.schedule(selectedWork.get()); in on_completed()
125 auto selectedWork = on_exception( in on_next() local128 if (selectedWork.empty()) { in on_next()131 … localState->worker.schedule(localState->worker.now() + localState->period, selectedWork.get()); in on_next()139 auto selectedWork = on_exception( in on_error() local142 if (selectedWork.empty()) { in on_error()145 localState->worker.schedule(selectedWork.get()); in on_error()153 auto selectedWork = on_exception( in on_completed() local156 if (selectedWork.empty()) { in on_completed()159 … localState->worker.schedule(localState->worker.now() + localState->period, selectedWork.get()); in on_completed()
177 auto selectedWork = on_exception( in on_next() local180 if (selectedWork.empty()) { in on_next()183 localState->worker.schedule(selectedWork.get()); in on_next()192 auto selectedWork = on_exception( in on_error() local195 if (selectedWork.empty()) { in on_error()198 localState->worker.schedule(selectedWork.get()); in on_error()207 auto selectedWork = on_exception( in on_completed() local210 if (selectedWork.empty()) { in on_completed()213 localState->worker.schedule(selectedWork.get()); in on_completed()
174 auto selectedWork = on_exception( in on_next() local177 if (selectedWork.empty()) { in on_next()180 localState->worker.schedule(selectedWork.get()); in on_next()187 auto selectedWork = on_exception( in on_error() local190 if (selectedWork.empty()) { in on_error()193 localState->worker.schedule(selectedWork.get()); in on_error()201 auto selectedWork = on_exception( in on_completed() local204 if (selectedWork.empty()) { in on_completed()207 localState->worker.schedule(selectedWork.get()); in on_completed()
152 auto selectedWork = on_exception( in on_next() local155 if (selectedWork.empty()) { in on_next()158 localState->worker.schedule(selectedWork.get()); in on_next()167 auto selectedWork = on_exception( in on_error() local170 if (selectedWork.empty()) { in on_error()173 localState->worker.schedule(selectedWork.get()); in on_error()184 auto selectedWork = on_exception( in on_completed() local187 if (selectedWork.empty()) { in on_completed()190 localState->worker.schedule(selectedWork.get()); in on_completed()
212 auto selectedWork = on_exception( in on_next() local215 if (selectedWork.empty()) { in on_next()218 localState->worker.schedule(selectedWork.get()); in on_next()229 auto selectedWork = on_exception( in on_error() local232 if (selectedWork.empty()) { in on_error()235 localState->worker.schedule(selectedWork.get()); in on_error()246 auto selectedWork = on_exception( in on_completed() local249 if (selectedWork.empty()) { in on_completed()252 localState->worker.schedule(selectedWork.get()); in on_completed()
189 auto selectedWork = on_exception( in on_next() local192 if (selectedWork.empty()) { in on_next()195 localState->worker.schedule(selectedWork.get()); in on_next()206 auto selectedWork = on_exception( in on_error() local209 if (selectedWork.empty()) { in on_error()212 localState->worker.schedule(selectedWork.get()); in on_error()223 auto selectedWork = on_exception( in on_completed() local226 if (selectedWork.empty()) { in on_completed()229 localState->worker.schedule(selectedWork.get()); in on_completed()
192 auto selectedWork = on_exception( in on_next() local195 if (selectedWork.empty()) { in on_next()198 localState->worker.schedule(selectedWork.get()); in on_next()205 auto selectedWork = on_exception( in on_error() local208 if (selectedWork.empty()) { in on_error()211 localState->worker.schedule(selectedWork.get()); in on_error()227 auto selectedWork = on_exception( in on_completed() local230 if (selectedWork.empty()) { in on_completed()233 localState->worker.schedule(selectedWork.get()); in on_completed()