Searched refs:pending_events_ (Results 1 – 2 of 2) sorted by relevance
56 if (pending_events_.wait_to_take(100ms)) { in RunLoop()58 writer->Write(pending_events_.take()); in RunLoop()76 pending_events_.push(std::move(event)); in OnIncomingEvent()82 common::BlockingQueue<T> pending_events_; variable
110 return pending_events_.RunLoop(context, writer); in StreamEvents()193 pending_events_.OnIncomingEvent(std::move(response)); in on_event()209 pending_events_.OnIncomingEvent(std::move(response)); in on_complete()217 pending_events_.OnIncomingEvent(std::move(response)); in on_status()223 ::bluetooth::grpc::GrpcEventQueue<::blueberry::facade::Data> pending_events_{"StreamEvents"};