Searched refs:obs (Results 1 – 2 of 2) sorted by relevance
458 auto obs = rxcpp::observable<>::create<PerfettoStateChange>( in CreatePerfettoStateStream() local514 return obs; in CreatePerfettoStateStream()
2660 rxcpp::observable<T>& obs = pair.first; in subscribe_drain() local2665 obs.subscribe([&vec](auto&& x) { in subscribe_drain()