Searched refs:subscriber (Results 1 – 3 of 3) sorted by relevance
323 void Subscribe(rxcpp::subscriber<RefWrapper> subscriber) { in Subscribe()326 subscriber_ = std::move(subscriber); in Subscribe()387 std::optional<rxcpp::subscriber<RefWrapper>> subscriber_;423 [&](rxcpp::subscriber<AppLaunchEventRefWrapper> subscriber) { in InitializeRxGraph() argument424 app_launch_event_subject_.Subscribe(std::move(subscriber)); in InitializeRxGraph()
203 rxcpp::subscriber<PerfettoStateChange> destination, in StateChangedSubject()222 rxcpp::subscriber<PerfettoStateChange> dest;460 (rxcpp::subscriber<PerfettoStateChange> subscriber) { in CreatePerfettoStateStream() argument462 new StateChangedSubject{perfetto_config, subscriber, perfetto_consumer}}; in CreatePerfettoStateStream()500 subscriber.add([safe_handle]() { in CreatePerfettoStateStream()
546 void TreeTraversalPreOrderObservableImpl(rx::subscriber<TSimple> dest, T&& node, F&& fn) { in TreeTraversalPreOrderObservableImpl()610 [node=node,fn=std::forward<F>(fn)](rx::subscriber<T_simple> dest) { in TreeTraversalPreOrderObservable()