Searched refs:pendingCompletions (Results 1 – 7 of 7) sorted by relevance
91 , pendingCompletions(0) in on_subscribe()99 int pendingCompletions; in on_subscribe() member123 ++state->pendingCompletions; in on_subscribe()143 --state->pendingCompletions; in on_subscribe()163 if (state->pendingCompletions == 1) { in on_subscribe()170 ++state->pendingCompletions; in on_subscribe()179 if (--state->pendingCompletions == 0) { in on_subscribe()
105 , pendingCompletions(0) in on_subscribe()113 int pendingCompletions; in on_subscribe() member137 ++state->pendingCompletions; in on_subscribe()159 ++state->pendingCompletions; in on_subscribe()171 if(--state->pendingCompletions == 0) { in on_subscribe()180 if (--state->pendingCompletions == 0) { in on_subscribe()196 if(--state->pendingCompletions == 0) { in on_subscribe()205 if (--state->pendingCompletions == 0) { in on_subscribe()
112 , pendingCompletions(0) in on_subscribe()120 int pendingCompletions; in on_subscribe() member143 ++state->pendingCompletions; in on_subscribe()165 ++state->pendingCompletions; in on_subscribe()181 if (--state->pendingCompletions == 0) { in on_subscribe()196 if (--state->pendingCompletions == 0) { in on_subscribe()
136 , pendingCompletions(0) in on_subscribe()143 int pendingCompletions; in on_subscribe() member166 ++state->pendingCompletions; in on_subscribe()189 ++state->pendingCompletions; in on_subscribe()206 if (--state->pendingCompletions == 0) { in on_subscribe()221 if (--state->pendingCompletions == 0) { in on_subscribe()
181 if (--state->pendingCompletions == 0) { in subscribe_one()212 , pendingCompletions(sizeof... (ObservableN)) in on_subscribe()221 mutable int pendingCompletions; in on_subscribe() member
213 if (--state->pendingCompletions == 0) { in subscribe_one()244 , pendingCompletions(sizeof... (ObservableN)) in on_subscribe()253 mutable int pendingCompletions; in on_subscribe() member