Searched refs:RequestAndJobEvent (Results 1 – 1 of 1) sorted by relevance
1136 using RequestAndJobEvent = std::pair<RequestId, JobScheduledEvent>; in InitializeRxGraphForJobScheduledEvents() typedef1138 job_scheduled_events_ = rxcpp::observable<>::create<RequestAndJobEvent>( in InitializeRxGraphForJobScheduledEvents()1139 [&](rxcpp::subscriber<RequestAndJobEvent> subscriber) { in InitializeRxGraphForJobScheduledEvents()1147 .tap([this](const RequestAndJobEvent& e) { in InitializeRxGraphForJobScheduledEvents()1164 .tap([](const RequestAndJobEvent& e) { in InitializeRxGraphForJobScheduledEvents()1177 [this](const RequestAndJobEvent& e) { in InitializeRxGraphForJobScheduledEvents()