Cross Reference: /external/libbrillo/brillo/streams/fake_stream

Lines Matching refs:stream_
31     stream_.reset(new FakeStream{mode, &clock_});
42     bool ok = stream_->ReadNonBlocking(data.data(), data.size(), &size_read,
56     if (!stream_->WriteNonBlocking(data.data(), data.size(), &written, nullptr))
64   std::unique_ptr<FakeStream> stream_;
70   EXPECT_TRUE(stream_->IsOpen());
71   EXPECT_TRUE(stream_->CanRead());
72   EXPECT_FALSE(stream_->CanWrite());
73   EXPECT_FALSE(stream_->CanSeek());
74   EXPECT_FALSE(stream_->CanGetSize());
75   EXPECT_EQ(0, stream_->GetSize());
76   EXPECT_EQ(0, stream_->GetRemainingSize());
77   EXPECT_EQ(0, stream_->GetPosition());
82   EXPECT_TRUE(stream_->IsOpen());
83   EXPECT_FALSE(stream_->CanRead());
84   EXPECT_TRUE(stream_->CanWrite());
85   EXPECT_FALSE(stream_->CanSeek());
86   EXPECT_FALSE(stream_->CanGetSize());
87   EXPECT_EQ(0, stream_->GetSize());
88   EXPECT_EQ(0, stream_->GetRemainingSize());
89   EXPECT_EQ(0, stream_->GetPosition());
94   EXPECT_TRUE(stream_->IsOpen());
95   EXPECT_TRUE(stream_->CanRead());
96   EXPECT_TRUE(stream_->CanWrite());
97   EXPECT_FALSE(stream_->CanSeek());
98   EXPECT_FALSE(stream_->CanGetSize());
99   EXPECT_EQ(0, stream_->GetSize());
100   EXPECT_EQ(0, stream_->GetRemainingSize());
101   EXPECT_EQ(0, stream_->GetPosition());
115   stream_->AddReadPacketString({}, "foo");
129   stream_->AddReadPacketString({}, "foobar");
147   stream_->AddReadPacketString({}, "foobar");
148   stream_->AddReadPacketString({}, "baz");
149   stream_->AddReadPacketString({}, "quux");
172   stream_->AddReadPacketString({}, "foo-bar");
180   stream_->AddReadPacketString({}, "foobar");
181   stream_->AddReadPacketString(base::TimeDelta::FromSeconds(1), "baz");
205   stream_->AddReadPacketString({}, "foobar");
206   stream_->QueueReadErrorWithMessage(base::TimeDelta::FromSeconds(1),
208   stream_->AddReadPacketString({}, "baz");
245       stream_->WaitForData(Stream::AccessMode::READ,
251   stream_->AddReadPacketString({}, "foobar");
253       stream_->WaitForData(Stream::AccessMode::READ,
259   stream_->ClearReadQueue();
262   stream_->AddReadPacketString(one_sec_delay, "baz");
265       stream_->WaitForData(Stream::AccessMode::READ,
278   stream_->AddReadPacketString({}, input_data.substr(0, split_pos));
279   stream_->AddReadPacketString(one_sec_delay, input_data.substr(split_pos));
297   EXPECT_TRUE(stream_->ReadAllAsync(
316   stream_->ExpectWritePacketSize({}, 6);
321   EXPECT_EQ("foobar", stream_->GetFlushedOutputDataAsString());
327   stream_->ExpectWritePacketSize({}, 3);
331   stream_->ExpectWritePacketSize({}, 3);
334   stream_->ExpectWritePacketSize({}, 3);
337   EXPECT_EQ("foobarquu", stream_->GetFlushedOutputDataAsString());
343   stream_->ExpectWritePacketString({}, "foo");
344   stream_->ExpectWritePacketString({}, "bar");
348   stream_->ExpectWritePacketString({}, "foo");
349   stream_->ExpectWritePacketString({}, "baz");
353   stream_->ExpectWritePacketString({}, "foobar");
364   stream_->ExpectWritePacketSize({}, 3);
365   stream_->ExpectWritePacketSize(delay, 3);
373   EXPECT_EQ("foobar", stream_->GetFlushedOutputDataAsString());
381   stream_->ExpectWritePacketSize({}, 3);
382   stream_->QueueWriteError({});
383   stream_->ExpectWritePacketSize({}, 3);
384   stream_->QueueWriteErrorWithMessage(delay, "Dummy message");
385   stream_->ExpectWritePacketString({}, "foobar");
410       stream_->WaitForData(Stream::AccessMode::WRITE,
416   stream_->ExpectWritePacketString({}, "foobar");
418       stream_->WaitForData(Stream::AccessMode::WRITE,
424   stream_->ClearWriteQueue();
427   stream_->ExpectWritePacketString(one_sec_delay, "baz");
430       stream_->WaitForData(Stream::AccessMode::WRITE,
443   stream_->ExpectWritePacketString({}, output_data.substr(0, split_pos));
444   stream_->ExpectWritePacketString(one_sec_delay,
460   EXPECT_TRUE(stream_->WriteAllAsync(
469   EXPECT_EQ(output_data, stream_->GetFlushedOutputDataAsString());
485   stream_->AddReadPacketString(one_sec_delay, "foo");
486   stream_->ExpectWritePacketString(two_sec_delay, "bar");
489   EXPECT_TRUE(stream_->WaitForData(Stream::AccessMode::READ_WRITE,
498   stream_->ClearReadQueue();
499   stream_->AddReadPacketString(two_sec_delay, "foo");
501   EXPECT_TRUE(stream_->WaitForData(Stream::AccessMode::READ_WRITE,
512   EXPECT_TRUE(stream_->WaitForData(Stream::AccessMode::READ_WRITE,
520   stream_->ClearReadQueue();
521   stream_->ClearWriteQueue();
522   stream_->AddReadPacketString(one_sec_delay, "foo");
523   stream_->ExpectWritePacketString(one_sec_delay, "bar");
526   EXPECT_TRUE(stream_->WaitForData(Stream::AccessMode::READ_WRITE,