Lines Matching refs:demuxer_
56 MessageDemuxer demuxer_{FakeClock::now, MessageDemuxer::kDefaultBufferLimit}; member in openscreen::osp::__anon61b657190111::MessageDemuxerTest
62 MessageDemuxer::MessageWatch watch = demuxer_.WatchMessageType( in TEST_F()
68 demuxer_.OnStreamData(endpoint_id_ + 1, 14, buffer_.data(), buffer_.size()); in TEST_F()
84 demuxer_.OnStreamData(endpoint_id_, connection_id_, buffer_.data(), in TEST_F()
90 demuxer_.OnStreamData(endpoint_id_, connection_id_, buffer_.data(), in TEST_F()
98 MessageDemuxer::MessageWatch watch = demuxer_.WatchMessageType( in TEST_F()
118 demuxer_.OnStreamData(endpoint_id_, connection_id_, buffer_.data(), in TEST_F()
120 demuxer_.OnStreamData(endpoint_id_, connection_id_, in TEST_F()
129 MessageDemuxer::MessageWatch watch = demuxer_.SetDefaultMessageTypeWatch( in TEST_F()
147 demuxer_.OnStreamData(endpoint_id_, connection_id_, buffer_.data(), in TEST_F()
158 demuxer_.SetDefaultMessageTypeWatch( in TEST_F()
162 MessageDemuxer::MessageWatch watch = demuxer_.WatchMessageType( in TEST_F()
182 demuxer_.OnStreamData(endpoint_id_ + 1, 14, buffer_.data(), buffer_.size()); in TEST_F()
198 demuxer_.OnStreamData(endpoint_id_, connection_id_, buffer_.data(), in TEST_F()
218 MessageDemuxer::MessageWatch watch = demuxer_.WatchMessageType( in TEST_F()
223 demuxer_.OnStreamData(endpoint_id_, connection_id_, buffer_.data(), in TEST_F()
234 MessageDemuxer::MessageWatch init_watch = demuxer_.WatchMessageType( in TEST_F()
259 MessageDemuxer::MessageWatch watch = demuxer_.WatchMessageType( in TEST_F()
264 demuxer_.OnStreamData(endpoint_id_, connection_id_, buffer_.data(), in TEST_F()
272 demuxer_.OnStreamData(endpoint_id_, connection_id_, buffer.data(), in TEST_F()
297 MessageDemuxer::MessageWatch watch = demuxer_.SetDefaultMessageTypeWatch( in TEST_F()
300 demuxer_.OnStreamData(endpoint_id_, connection_id_, buffer_.data(), in TEST_F()