Searched refs:pending_events_ (Results 1 – 4 of 4) sorted by relevance
53 pending_events_.clear(); in RunLoop()57 if (pending_events_.wait_to_take(500ms)) { in RunLoop()59 writer->Write(pending_events_.take()); in RunLoop()77 pending_events_.push(std::move(event)); in OnIncomingEvent()83 common::BlockingQueue<T> pending_events_; variable
54 return pending_events_.RunLoop(context, writer); in StartScan()87 pending_events_.OnIncomingEvent(std::move(le_report_msg)); in on_advertisements()103 pending_events_.OnIncomingEvent(std::move(le_report_msg)); in on_advertisements()121 pending_events_.OnIncomingEvent(std::move(le_report_msg)); in on_advertisements()136 pending_events_.OnIncomingEvent(std::move(le_report_msg)); in on_timeout()145 ::bluetooth::grpc::GrpcEventQueue<LeReportMsg> pending_events_{"LeReports"};
104 return pending_events_.RunLoop(context, writer); in FetchEvents()192 pending_events_.OnIncomingEvent(std::move(response)); in on_event()208 pending_events_.OnIncomingEvent(std::move(response)); in on_complete()216 pending_events_.OnIncomingEvent(std::move(response)); in on_status()222 ::bluetooth::grpc::GrpcEventQueue<EventMsg> pending_events_{"FetchHciEvent"};
114 return pending_events_.RunLoop(context, writer); in SetInquiryMode()182 pending_events_.OnIncomingEvent(std::move(inquiry_result_msg)); in on_incoming_inquiry_result()188 pending_events_.OnIncomingEvent(std::move(inquiry_result_msg)); in on_incoming_inquiry_complete()211 ::bluetooth::grpc::GrpcEventQueue<InquiryResultMsg> pending_events_{"InquiryResponses"};