Searched refs:inode_results (Results 1 – 3 of 3) sorted by relevance
374 auto/*observable<InodeResult>*/ inode_results = all in main() local379 inode_results.subscribe( in main()
928 auto/*observable[2]*/ [inode_results, connectable] = SearchDirectoriesForMatchingInodes( in FindFilenamesFromInodes()933 return inode_results.ref_count(connectable); in FindFilenamesFromInodes()974 auto/*observable[2]*/ [inode_results, connectable] = SearchDirectoriesForMatchingInodes( in FindFilenamesFromInodesPair()982 return {inode_results, std::move(connectable_ptr)}; in FindFilenamesFromInodesPair()
459 rxcpp::observable<InodeResult> inode_results) { in ReduceResolvedInodesToMap() argument460 return inode_results.reduce( in ReduceResolvedInodesToMap()