Searched refs:observable (Results 1 – 25 of 27) sorted by relevance
12
65 rxcpp::observable<InodeResult>91 std::pair<rxcpp::observable<InodeResult>, std::unique_ptr<RxAnyConnectable>>102 rxcpp::observable<InodeResult>104 rxcpp::observable<Inode> inodes,107 rxcpp::observable<InodeResult>110 rxcpp::observable<InodeResult> FilterFilenamesForSpecificInodes(112 rxcpp::observable<InodeResult> all_inodes,119 rxcpp::observable<InodeResult> EmitAllFilenames(121 rxcpp::observable<InodeResult> all_inodes,
301 using ObservableT = rx::observable<ResultT>;567 auto MapExpectedOrLog(T&& observable, in MapExpectedOrLog() argument582 auto MapExpectedOrLogError(T&& observable) { in MapExpectedOrLogError() argument587 auto MapOptionalOrDrop(T&& observable) { in MapOptionalOrDrop() argument669 return rx::observable<>::create<T_simple>( in TreeTraversalPreOrderObservable()947 observable.connect(); in connect()953 : observable(observable) { in RxAnyConnectableFromObservable()956 rxcpp::connectable_observable<T> observable; member985 rxcpp::observable<InodeResult>1033 rxcpp::observable<InodeResult>[all …]
78 rxcpp::observable<InodeResult>79 FindFilenamesFromInodes(rxcpp::observable<Inode> inodes) const;82 virtual rxcpp::observable<InodeResult>94 virtual rxcpp::observable<InodeResult>
126 rxcpp::observable<InodeResult>127 InodeResolver::FindFilenamesFromInodes(rxcpp::observable<Inode> inodes) const { in FindFilenamesFromInodes()146 rxcpp::observable<InodeResult>152 rxcpp::observable<InodeResult> all_inodes = impl_->data_source_->EmitInodes(); in FindFilenamesFromInodes()165 rxcpp::observable<InodeResult>171 rxcpp::observable<InodeResult> all_inodes = impl_->data_source_->EmitInodes(); in EmitAll()
29 virtual rxcpp::observable<InodeResult>32 virtual rxcpp::observable<InodeResult>
71 virtual rxcpp::observable<InodeResult> EmitInodes() const override { in EmitInodes()100 virtual rxcpp::observable<InodeResult> EmitInodes() const override { in EmitInodes()103 return rx::observable<>::create<InodeResult>( in EmitInodes()
369 rxcpp::observable<InodeResult>371 return rxcpp::observable<>::create<InodeResult>( in FindFilenamesFromInodes()379 rxcpp::observable<InodeResult>385 return rxcpp::observable<>::create<InodeResult>( in EmitAll()
60 virtual rxcpp::observable<InodeResult> EmitInodes() const = 0;
36 T&& observable, in SubscribeAsync() argument41 observable=std::forward<T>(observable), in SubscribeAsync()43 observable in SubscribeAsync()55 T&& observable, in SubscribeAsync() argument61 observable=std::forward<T>(observable), in SubscribeAsync()64 observable in SubscribeAsync()
37 static std::string toString(const MediaObservableParcel& observable) { in toString() argument38 return "{" + ::aidl::android::media::toString(observable.type) + ", " + in toString()39 std::to_string(observable.value) + "}"; in toString()55 for (auto& observable : observables) { in onStatusChanged() local56 if (observable.type == MediaObservableType::kVideoSecureCodec || in onStatusChanged()57 observable.type == MediaObservableType::kVideoNonSecureCodec) { in onStatusChanged()
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()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()736 rxcpp::observable<ResolvedPageCacheFtraceEvent> resolved_events, in ApplyBlacklistToPageCacheEvents()[all …]
110 public static <T> SafeCloseable addThreadSafeCallback(final Observable<T> observable,112 return observable.addCallback(new Runnable() {115 callback.update(observable.get());
11 …ust not be exposed (synchronizing on this or class is still externally observable): method android…13 …ust not be exposed (synchronizing on this or class is still externally observable): method android…
476 auto obs = rxcpp::observable<>::create<PerfettoStateChange>( in CreatePerfettoStateStream()747 CreatePerfettoStream(rxcpp::observable<PerfettoStreamCommand> input, in CreatePerfettoStream()816 return rxcpp::observable<>::just(std::move(wire_proto)).as_dynamic(); in CreatePerfettoStream()818 return rxcpp::observable<>::empty<PerfettoTraceProto>().as_dynamic(); in CreatePerfettoStream()846 rxcpp::observable<PerfettoTraceProto> RxProducerFactory::CreateTraceStream( in CreateTraceStream()847 rxcpp::observable<PerfettoStreamCommand> commands) { in CreateTraceStream()
187 rxcpp::observable<PerfettoTraceProto> CreateTraceStream(188 rxcpp::observable<PerfettoStreamCommand> commands);
100 rxcpp::observable<>::just(PerfettoStreamCommand::kStartTracing) in CollectPerfettoTraceBufferViaAbstractions()105 rxcpp::observable<>::interval(std::chrono::milliseconds(arg_duration_ms * 2)) in CollectPerfettoTraceBufferViaAbstractions()
126 rxcpp::observable<int> history_id_observable_;220 auto history_id_observable = rxcpp::observable<>::create<int>( in OnNewEvent()483 rxcpp::observable<>::just(PerfettoStreamCommand::kStartTracing) in StartTracing()488 rxcpp::observable<>::interval(std::chrono::milliseconds(10000)) in StartTracing()1049 app_launch_events_ = rxcpp::observable<>::create<AppLaunchEventRefWrapper>( in InitializeRxGraph()1138 job_scheduled_events_ = rxcpp::observable<>::create<RequestAndJobEvent>( in InitializeRxGraphForJobScheduledEvents()1306 rxcpp::observable<AppLaunchEventRefWrapper> app_launch_events_;1310 rxcpp::observable<std::pair<RequestId, JobScheduledEvent>> job_scheduled_events_;1313 rxcpp::observable<RequestId> completed_requests_;
135 for (auto &observable : observer.second.filters) { in dump() local138 if (((uint64_t)observable.eventFilter & (uint64_t)event) != 0) { in dump()146 toString(observable.type).c_str(), enabledEventsStr.c_str()); in dump()
237 …ust not be exposed (synchronizing on this or class is still externally observable): method android…239 …ust not be exposed (synchronizing on this or class is still externally observable): method android…241 …ust not be exposed (synchronizing on this or class is still externally observable): method android…243 …ust not be exposed (synchronizing on this or class is still externally observable): method android…245 …ust not be exposed (synchronizing on this or class is still externally observable): method android…247 …ust not be exposed (synchronizing on this or class is still externally observable): method android…249 …ust not be exposed (synchronizing on this or class is still externally observable): method android…251 …ust not be exposed (synchronizing on this or class is still externally observable): method android…253 …ust not be exposed (synchronizing on this or class is still externally observable): method android…
4 externally observable): method android.net.NetworkInfo.toString()
48 static std::string toString(const MediaObservableParcel& observable) { in toString()49 return "{" + ::aidl::android::media::toString(observable.type) in toString()50 + ", " + std::to_string(observable.value) + "}"; in toString()65 for (auto &observable : event.observables) { in toString() local69 observableStr += toString(observable); in toString()
1047 bool observable = true; in VisitDeoptimize() local1056 observable = std::any_of( in VisitDeoptimize()1064 if (observable) { in VisitDeoptimize()
1dictionary=main:fr,locale=fr,description=Français,date=1414726264, ...
1dictionary=main:en_us,locale=en_US,description=English (US),date ...
1dictionary=main:en_gb,locale=en_GB,description=English (UK),date ...