123     return rxcpp::observable<>::iterate(set_).map(  // XX: should we use identity_immediate here?  in IterateValues()
301   using ObservableT = rx::observable<ResultT>;
567 auto MapExpectedOrLog(T&& observable,  in MapExpectedOrLog()  argument
569   return observable.filter([log_level](const auto& result) {  in MapExpectedOrLog()
582 auto MapExpectedOrLogError(T&& observable) {  in MapExpectedOrLogError()  argument
583   return MapExpectedOrLog(std::forward<T>(observable), ::android::base::ERROR);  in MapExpectedOrLogError()
587 auto MapOptionalOrDrop(T&& observable) {  in MapOptionalOrDrop()  argument
588   return observable.filter([](const auto& result) {  in MapOptionalOrDrop()
669   return rx::observable<>::create<T_simple>(  in TreeTraversalPreOrderObservable()
922 rxcpp::observable<InodeResult> SearchDirectories::FindFilenamesFromInodes(  in FindFilenamesFromInodes()
947     observable.connect();  in connect()
952   RxAnyConnectableFromObservable(rxcpp::connectable_observable<T> observable)  in RxAnyConnectableFromObservable()
953     : observable(observable) {  in RxAnyConnectableFromObservable()
956   rxcpp::connectable_observable<T> observable;  member
962     MakeRxAnyConnectableFromObservable(rxcpp::connectable_observable<T> observable) {  in MakeRxAnyConnectableFromObservable()  argument
963   SearchDirectories::RxAnyConnectable* ptr = new RxAnyConnectableFromObservable<T>{observable};  in MakeRxAnyConnectableFromObservable()
967 std::pair<rxcpp::observable<InodeResult>, std::unique_ptr<SearchDirectories::RxAnyConnectable>>
985 rxcpp::observable<InodeResult>
987                                                rxcpp::observable<Inode> inodes,  in FindFilenamesFromInodes()
1033 rxcpp::observable<InodeResult>
1069 rxcpp::observable<InodeResult> SearchDirectories::FilterFilenamesForSpecificInodes(  in FilterFilenamesForSpecificInodes()
1070     rxcpp::observable<InodeResult> all_inodes,  in FilterFilenamesForSpecificInodes()
1265 rxcpp::observable<InodeResult> SearchDirectories::EmitAllFilenames(  in EmitAllFilenames()
1266     rxcpp::observable<InodeResult> all_inodes,  in EmitAllFilenames()