Searched refs:incoming_messages_ (Results 1 – 2 of 2) sorted by relevance
657 if (!incoming_messages_.empty()) { in AcceptIncomingMessages()661 std::swap(messages, incoming_messages_); in AcceptIncomingMessages()745 schedule_pump_task = incoming_messages_.empty() && io_task_runner_ && in ForwardMessage()748 incoming_messages_.emplace(std::move(message)); in ForwardMessage()
285 std::queue<ports::ScopedMessage> incoming_messages_; variable