Searched refs:receive_callbacks_ (Results 1 – 2 of 2) sorted by relevance
43 receive_callbacks_.clear(); in ~RpcBroker()53 OSP_DCHECK(receive_callbacks_.find(handle) == receive_callbacks_.end()) in RegisterMessageReceiverCallback()56 receive_callbacks_.emplace_back(handle, std::move(callback)); in RegisterMessageReceiverCallback()61 receive_callbacks_.erase_key(handle); in UnregisterMessageReceiverCallback()66 const auto entry = receive_callbacks_.find(message.handle()); in ProcessMessageFromRemote()67 if (entry == receive_callbacks_.end()) { in ProcessMessageFromRemote()83 return receive_callbacks_.find(handle) != receive_callbacks_.end(); in IsRegisteredForTesting()
80 FlatMap<Handle, ReceiveMessageCallback> receive_callbacks_; variable