Lines Matching refs:observable

92     rxcpp::observable<CompilationInput> file_infos) {  in ReadProtosFromFileNames()
174   auto filename_obs = rxcpp::observable<>::iterate(std::move(file_infos));  in ReadPerfettoTraceProtos()
175   rxcpp::observable<PerfettoTracePtrInfo> obs =  in ReadPerfettoTraceProtos()
304   return rxcpp::observable<>::create<PageCacheFtraceEvent>(  in SelectPageCacheFtraceEvents()
425     rxcpp::observable<PerfettoTracePtrInfo> traces) {  in SelectDistinctInodesFromTraces()
429       rxcpp::observable<PageCacheFtraceEvent> obs = SelectPageCacheFtraceEvents(std::move(trace));  in SelectDistinctInodesFromTraces()
450     rxcpp::observable<Inode> inodes,  in ResolveInodesToFileNames()
459       rxcpp::observable<InodeResult> inode_results) {  in ReduceResolvedInodesToMap()
556     rxcpp::observable<PerfettoTracePtrInfo> traces,  in ResolvePageCacheEntriesFromProtos()
563   rxcpp::observable<Inode> distinct_inodes_obs = distinct_inodes.as_dynamic();  in ResolvePageCacheEntriesFromProtos()
573       rxcpp::observable<PageCacheFtraceEvent> obs = SelectPageCacheFtraceEvents(std::move(trace));  in ResolvePageCacheEntriesFromProtos()
736     rxcpp::observable<ResolvedPageCacheFtraceEvent> resolved_events,  in ApplyBlacklistToPageCacheEvents()
761     rxcpp::observable<ResolvedPageCacheFtraceEvent> resolved_events) {  in CompilePageCacheEvents()