Lines Matching defs:byte_stream_input

49   bool Write(ByteStreamWriter* byte_stream_input, size_t buffer_size) {
50 return byte_stream_input->Write(NewIOBuffer(buffer_size), buffer_size);
105 scoped_ptr<ByteStreamWriter> byte_stream_input;
109 3 * 1024, &byte_stream_input, &byte_stream_output);
113 EXPECT_TRUE(Write(byte_stream_input.get(), 1024));
114 EXPECT_TRUE(Write(byte_stream_input.get(), 1024));
115 EXPECT_TRUE(Write(byte_stream_input.get(), 1024));
116 EXPECT_FALSE(Write(byte_stream_input.get(), 1));
117 EXPECT_FALSE(Write(byte_stream_input.get(), 1024));
119 byte_stream_input->Close(0);
120 EXPECT_EQ(4 * 1024U + 1U, byte_stream_input->GetTotalBufferedBytes());
123 EXPECT_EQ(4 * 1024U + 1U, byte_stream_input->GetTotalBufferedBytes());
154 EXPECT_EQ(1024U, byte_stream_input->GetTotalBufferedBytes());
160 scoped_ptr<ByteStreamWriter> byte_stream_input;
164 1024, &byte_stream_input, &byte_stream_output);
166 EXPECT_TRUE(Write(byte_stream_input.get(), 1));
175 byte_stream_input->Flush();
183 byte_stream_input->Flush();
189 byte_stream_input->Close(0);
200 scoped_ptr<ByteStreamWriter> byte_stream_input;
204 9 * 1024, &byte_stream_input, &byte_stream_output);
208 EXPECT_TRUE(Write(byte_stream_input.get(), 1024));
210 EXPECT_TRUE(Write(byte_stream_input.get(), 1024));
212 EXPECT_TRUE(Write(byte_stream_input.get(), 1024));
214 EXPECT_TRUE(Write(byte_stream_input.get(), 1024));
216 EXPECT_FALSE(Write(byte_stream_input.get(), 6 * 1024));
250 scoped_ptr<ByteStreamWriter> byte_stream_input;
259 3 * 1024, &byte_stream_input, &byte_stream_output);
262 byte_stream_input->Close(0);
271 3 * 1024, &byte_stream_input, &byte_stream_output);
274 EXPECT_TRUE(Write(byte_stream_input.get(), 1024));
275 byte_stream_input->Close(0);
289 3 * 1024, &byte_stream_input, &byte_stream_output);
292 byte_stream_input->Close(kFakeErrorCode);
301 3 * 1024, &byte_stream_input, &byte_stream_output);
304 EXPECT_TRUE(Write(byte_stream_input.get(), 1024));
305 byte_stream_input->Close(kFakeErrorCode);
320 scoped_ptr<ByteStreamWriter> byte_stream_input;
324 10000, &byte_stream_input, &byte_stream_output);
341 EXPECT_TRUE(Write(byte_stream_input.get(), 4000));
357 EXPECT_TRUE(Write(byte_stream_input.get(), 3000));
372 scoped_ptr<ByteStreamWriter> byte_stream_input;
376 10000, &byte_stream_input, &byte_stream_output);
391 byte_stream_input->RegisterCallback(
393 EXPECT_TRUE(Write(byte_stream_input.get(), 2000));
394 EXPECT_TRUE(Write(byte_stream_input.get(), 2001));
395 EXPECT_FALSE(Write(byte_stream_input.get(), 6000));
434 scoped_ptr<ByteStreamWriter> byte_stream_input;
438 10000, &byte_stream_input, &byte_stream_output);
450 EXPECT_TRUE(Write(byte_stream_input.get(), 4000));
481 scoped_ptr<ByteStreamWriter> byte_stream_input;
485 10000, &byte_stream_input, &byte_stream_output);
493 byte_stream_input->RegisterCallback(
495 EXPECT_TRUE(Write(byte_stream_input.get(), 2000));
496 EXPECT_TRUE(Write(byte_stream_input.get(), 2001));
497 EXPECT_FALSE(Write(byte_stream_input.get(), 6000));
513 byte_stream_input->RegisterCallback(
533 scoped_ptr<ByteStreamWriter> byte_stream_input;
537 10000, &byte_stream_input, &byte_stream_output);
547 byte_stream_input->Close(0);
553 scoped_ptr<ByteStreamWriter> byte_stream_input;
557 3 * 1024, &byte_stream_input, &byte_stream_output);
559 byte_stream_input->Close(0);
569 scoped_ptr<ByteStreamWriter> byte_stream_input;
573 3 * 1024, &byte_stream_input, &byte_stream_output);
575 byte_stream_input->Flush();
583 byte_stream_input->Close(0);
591 scoped_ptr<ByteStreamWriter> byte_stream_input;
596 &byte_stream_input, &byte_stream_output);
598 EXPECT_TRUE(Write(byte_stream_input.get(), 1));
601 EXPECT_FALSE(byte_stream_input->Write(empty_io_buffer,