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()89 pending_events_.OnIncomingEvent(std::move(le_report_msg)); in OnScanResult()102 ::bluetooth::grpc::GrpcEventQueue<LeReportMsg> pending_events_{"LeReports"};
106 return pending_events_.RunLoop(context, writer); in StreamEvents()188 pending_events_.OnIncomingEvent(std::move(response)); in on_event()204 pending_events_.OnIncomingEvent(std::move(response)); in on_complete()212 pending_events_.OnIncomingEvent(std::move(response)); in on_status()218 ::bluetooth::grpc::GrpcEventQueue<::bluetooth::facade::Data> pending_events_{"StreamEvents"};
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"};