Searched refs:current_completer (Results 1 – 1 of 1) sorted by relevance
94 mutable std::weak_ptr<completer_type> current_completer; member113 b->current_completer.reset(); in multicast_observer()179 auto current_completer = b->current_completer.lock(); in on_next() local180 if (!current_completer) { in on_next()182 b->current_completer = b->completer; in on_next()183 current_completer = b->current_completer.lock(); in on_next()185 if (!current_completer || current_completer->observers.empty()) { in on_next()188 for (auto& o : current_completer->observers) { in on_next()201 b->current_completer.reset(); in on_error()219 b->current_completer.reset(); in on_completed()