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
1051         app_launch_event_subject_.Subscribe(std::move(subscriber));  in InitializeRxGraph()
1139       [&](rxcpp::subscriber<RequestAndJobEvent> subscriber) {  in InitializeRxGraphForJobScheduledEvents()  argument
1140         job_scheduled_event_subject_.Subscribe(std::move(subscriber));  in InitializeRxGraphForJobScheduledEvents()