Searched refs:rx_lifetime_ (Results 1 – 1 of 1) sorted by relevance
117 std::optional<rxcpp::composite_subscription> rx_lifetime_; member161 rx_lifetime_ = StartTracing(std::move(component_name)); in OnNewEvent()191 rx_lifetime_ = StartTracing(std::move(component_name)); in OnNewEvent()286 if (rx_lifetime_) { in AbortTrace()290 rx_lifetime_->unsubscribe(); in AbortTrace()291 rx_lifetime_.reset(); in AbortTrace()298 DCHECK(rx_lifetime_.has_value()); in MarkPendingTrace()300 if (rx_lifetime_) { in MarkPendingTrace()306 rx_in_flight_.push_back(*std::move(rx_lifetime_)); in MarkPendingTrace()307 rx_lifetime_.reset(); in MarkPendingTrace()[all …]