80                                            uint64_t endpoint_id,  in MessageWatch()  argument
84       endpoint_id_(endpoint_id),  in MessageWatch()
129     uint64_t endpoint_id,  in WatchMessageType()  argument
132   auto callbacks_entry = message_callbacks_.find(endpoint_id);  in WatchMessageType()
136             .emplace(endpoint_id, std::map<msgs::Type, MessageCallback*>{})  in WatchMessageType()
142   auto endpoint_entry = buffers_.find(endpoint_id);  in WatchMessageType()
149         HandleStreamBufferLoop(endpoint_id, buffer.first, callbacks_entry,  in WatchMessageType()
154   return MessageWatch(this, false, endpoint_id, message_type);  in WatchMessageType()
164     auto endpoint_id = endpoint_buffers.first;  in SetDefaultMessageTypeWatch()  local
171         auto callbacks_entry = message_callbacks_.find(endpoint_id);  in SetDefaultMessageTypeWatch()
172         HandleStreamBufferLoop(endpoint_id, connection_id, callbacks_entry,  in SetDefaultMessageTypeWatch()
180 void MessageDemuxer::OnStreamData(uint64_t endpoint_id,  in OnStreamData()  argument
184   OSP_VLOG << __func__ << ": [" << endpoint_id << ", " << connection_id  in OnStreamData()
186   auto& stream_map = buffers_[endpoint_id];  in OnStreamData()
190       buffers_.erase(endpoint_id);  in OnStreamData()
196   auto callbacks_entry = message_callbacks_.find(endpoint_id);  in OnStreamData()
197   HandleStreamBufferLoop(endpoint_id, connection_id, callbacks_entry, &buffer);  in OnStreamData()
203 void MessageDemuxer::StopWatchingMessageType(uint64_t endpoint_id,  in StopWatchingMessageType()  argument
205   auto& message_map = message_callbacks_[endpoint_id];  in StopWatchingMessageType()
215     uint64_t endpoint_id,  in HandleStreamBufferLoop()  argument
225       result = HandleStreamBuffer(endpoint_id, connection_id,  in HandleStreamBufferLoop()
231         result = HandleStreamBuffer(endpoint_id, connection_id,  in HandleStreamBufferLoop()
242     uint64_t endpoint_id,  in HandleStreamBuffer()  argument
265         endpoint_id, connection_id, message_type.value(),  in HandleStreamBuffer()