Searched refs:rx_in_flight_ (Results 1 – 1 of 1) sorted by relevance
146 std::vector<rxcpp::composite_subscription> rx_in_flight_; member578 rx_in_flight_.erase(std::remove(rx_in_flight_.begin(), in AbortTrace()579 rx_in_flight_.end(), *rx_lifetime_), in AbortTrace()580 rx_in_flight_.end()); in AbortTrace()600 rx_in_flight_.push_back(*std::move(rx_lifetime_)); in MarkPendingTrace()