55 ErrorOr<msgs::Type> MessageTypeDecoder::DecodeType(  in DecodeType()
64   msgs::Type parsed_type =  in DecodeType()
65       msgs::TypeEnumValidator::SafeCast(message_type.value());  in DecodeType()
66   if (parsed_type == msgs::Type::kUnknown) {  in DecodeType()
81                                            msgs::Type message_type)  in MessageWatch()
130     msgs::Type message_type,  in WatchMessageType()
136             .emplace(endpoint_id, std::map<msgs::Type, MessageCallback*>{})  in WatchMessageType()
147       auto buffered_type = static_cast<msgs::Type>(buffer.second[0]);  in WatchMessageType()
158     msgs::Type message_type,  in SetDefaultMessageTypeWatch()
168       auto buffered_type = static_cast<msgs::Type>(stream_map.second[0]);  in SetDefaultMessageTypeWatch()
204                                              msgs::Type message_type) {  in StopWatchingMessageType()
210 void MessageDemuxer::StopDefaultMessageTypeWatch(msgs::Type message_type) {  in StopDefaultMessageTypeWatch()
217     std::map<uint64_t, std::map<msgs::Type, MessageCallback*>>::iterator  in HandleStreamBufferLoop()
244     std::map<msgs::Type, MessageCallback*>* message_callbacks,  in HandleStreamBuffer()
252     ErrorOr<msgs::Type> message_type =  in HandleStreamBuffer()