Searched refs:subscriber (Results 1 – 7 of 7) sorted by relevance
| /system/iorap/src/common/ |
| D | rx_async.h | 37 U&& subscriber) { in SubscribeAsync() argument
42 subscriber=std::forward<U>(subscriber)]() mutable { in SubscribeAsync()
46 std::forward<decltype(subscriber)>(subscriber)); in SubscribeAsync()
|
| /system/iorap/src/manager/ |
| D | event_manager.cc | 125 std::optional<rxcpp::subscriber<int>> history_id_subscriber_;
221 [&](rxcpp::subscriber<int> subscriber) { in OnNewEvent() argument
222 history_id_subscriber_ = std::move(subscriber); in OnNewEvent()
797 void Subscribe(rxcpp::subscriber<RefWrapper> subscriber) { in Subscribe()
800 subscriber_ = std::move(subscriber); in Subscribe()
861 std::optional<rxcpp::subscriber<RefWrapper>> subscriber_;
868 void Subscribe(rxcpp::subscriber<std::pair<RequestId, JobScheduledEvent>> subscriber) { in Subscribe()
871 subscriber_ = std::move(subscriber); in Subscribe()
916 std::optional<rxcpp::subscriber<std::pair<RequestId, JobScheduledEvent>>> subscriber_;
1050 [&](rxcpp::subscriber<AppLaunchEventRefWrapper> subscriber) { in InitializeRxGraph() argument
[all …]
|
| /system/iorap/src/inode2filename/ |
| D | out_of_process_inode_resolver.cc | 235 void EmitFromCommandFind(rxcpp::subscriber<InodeResult>& dest, in EmitFromCommandFind()
251 void EmitFromCommandAll(rxcpp::subscriber<InodeResult>& dest, in EmitFromCommandAll()
258 void EmitFromCommandWithArgv(rxcpp::subscriber<InodeResult>& dest, in EmitFromCommandWithArgv()
374 rxcpp::subscriber<InodeResult> s) { in FindFilenamesFromInodes()
386 [self](rxcpp::subscriber<InodeResult> s) { in EmitAll()
|
| D | data_source.cc | 104 [file_name](rx::subscriber<InodeResult> dest) { in EmitInodes()
|
| D | search_directories.cc | 607 void TreeTraversalPreOrderObservableImpl(rx::subscriber<TSimple> dest, T&& node, F&& fn) { in TreeTraversalPreOrderObservableImpl()
671 [node=node,fn=std::forward<F>(fn)](rx::subscriber<T_simple> dest) { in TreeTraversalPreOrderObservable()
|
| /system/iorap/src/perfetto/ |
| D | rx_producer.cc | 209 rxcpp::subscriber<PerfettoStateChange> destination, in StateChangedSubject()
228 rxcpp::subscriber<PerfettoStateChange> dest;
478 (rxcpp::subscriber<PerfettoStateChange> subscriber) { in CreatePerfettoStateStream() argument
480 new StateChangedSubject{perfetto_config, subscriber, perfetto_consumer}}; in CreatePerfettoStateStream()
523 subscriber.add([safe_handle]() { in CreatePerfettoStateStream()
|
| /system/iorap/src/compiler/ |
| D | compiler.cc | 308 (rxcpp::subscriber<PageCacheFtraceEvent> sub) { in SelectPageCacheFtraceEvents()
|