Lines Matching refs:Stream
30 void CreateStream(Stream::AccessMode mode) { in CreateStream()
69 CreateStream(Stream::AccessMode::READ); in TEST_F()
81 CreateStream(Stream::AccessMode::WRITE); in TEST_F()
93 CreateStream(Stream::AccessMode::READ_WRITE); in TEST_F()
105 CreateStream(Stream::AccessMode::READ); in TEST_F()
114 CreateStream(Stream::AccessMode::READ); in TEST_F()
128 CreateStream(Stream::AccessMode::READ); in TEST_F()
146 CreateStream(Stream::AccessMode::READ); in TEST_F()
179 CreateStream(Stream::AccessMode::READ); in TEST_F()
204 CreateStream(Stream::AccessMode::READ); in TEST_F()
234 CreateStream(Stream::AccessMode::READ); in TEST_F()
239 auto callback = [&call_count](Stream::AccessMode mode) { in TEST_F()
241 EXPECT_EQ(Stream::AccessMode::READ, mode); in TEST_F()
244 EXPECT_TRUE(stream_->WaitForData(Stream::AccessMode::READ, in TEST_F()
250 EXPECT_TRUE(stream_->WaitForData(Stream::AccessMode::READ, in TEST_F()
260 EXPECT_TRUE(stream_->WaitForData(Stream::AccessMode::READ, in TEST_F()
267 CreateStream(Stream::AccessMode::READ); in TEST_F()
300 CreateStream(Stream::AccessMode::WRITE); in TEST_F()
305 CreateStream(Stream::AccessMode::WRITE); in TEST_F()
315 CreateStream(Stream::AccessMode::WRITE); in TEST_F()
331 CreateStream(Stream::AccessMode::WRITE); in TEST_F()
350 CreateStream(Stream::AccessMode::WRITE); in TEST_F()
367 CreateStream(Stream::AccessMode::WRITE); in TEST_F()
389 CreateStream(Stream::AccessMode::WRITE); in TEST_F()
394 auto callback = [&call_count](Stream::AccessMode mode) { in TEST_F()
396 EXPECT_EQ(Stream::AccessMode::WRITE, mode); in TEST_F()
399 EXPECT_TRUE(stream_->WaitForData(Stream::AccessMode::WRITE, in TEST_F()
405 EXPECT_TRUE(stream_->WaitForData(Stream::AccessMode::WRITE, in TEST_F()
415 EXPECT_TRUE(stream_->WaitForData(Stream::AccessMode::WRITE, in TEST_F()
422 CreateStream(Stream::AccessMode::WRITE); in TEST_F()
453 CreateStream(Stream::AccessMode::READ_WRITE); in TEST_F()
458 auto callback = [&call_count](Stream::AccessMode mode, in TEST_F()
459 Stream::AccessMode expected_mode) { in TEST_F()
468 EXPECT_TRUE(stream_->WaitForData(Stream::AccessMode::READ_WRITE, in TEST_F()
470 Stream::AccessMode::READ), in TEST_F()
479 EXPECT_TRUE(stream_->WaitForData(Stream::AccessMode::READ_WRITE, in TEST_F()
481 Stream::AccessMode::WRITE), in TEST_F()
489 EXPECT_TRUE(stream_->WaitForData(Stream::AccessMode::READ_WRITE, in TEST_F()
491 Stream::AccessMode::READ_WRITE), in TEST_F()
502 EXPECT_TRUE(stream_->WaitForData(Stream::AccessMode::READ_WRITE, in TEST_F()
504 Stream::AccessMode::READ_WRITE), in TEST_F()