Lines Matching full:callback
13 #include "base/functional/callback.h"
85 TestCompletionCallback callback; in TEST_F() local
90 int rv = stream.Open(temp_file_path(), flags, callback.callback()); in TEST_F()
92 EXPECT_THAT(callback.WaitForResult(), IsOk()); in TEST_F()
94 EXPECT_THAT(stream.Close(callback.callback()), IsError(ERR_IO_PENDING)); in TEST_F()
95 EXPECT_THAT(callback.WaitForResult(), IsOk()); in TEST_F()
100 TestCompletionCallback callback; in TEST_F() local
105 int rv = stream->Open(temp_file_path(), flags, callback.callback()); in TEST_F()
107 EXPECT_THAT(callback.WaitForResult(), IsOk()); in TEST_F()
109 EXPECT_THAT(stream->Close(callback.callback()), IsError(ERR_IO_PENDING)); in TEST_F()
114 // The file should now be closed, though the callback has not been called. in TEST_F()
120 TestCompletionCallback callback; in TEST_F() local
131 ASSERT_THAT(read_stream->Seek(0, callback64.callback()), in TEST_F()
137 rv = read_stream->Read(read_buffer.get(), kTestDataSize, callback.callback()); in TEST_F()
138 ASSERT_EQ(kTestDataSize, callback.GetResult(rv)); in TEST_F()
150 ASSERT_THAT(write_stream->Seek(0, callback64.callback()), in TEST_F()
155 callback.callback()); in TEST_F()
156 ASSERT_EQ(kTestDataSize, callback.GetResult(rv)); in TEST_F()
168 TestCompletionCallback callback; in TEST_F() local
176 rv = stream.Seek(5, callback64.callback()); in TEST_F()
182 rv = stream.Read(buf.get(), buf->size(), callback.callback()); in TEST_F()
183 EXPECT_THAT(callback.GetResult(rv), IsError(ERR_UNEXPECTED)); in TEST_F()
193 TestCompletionCallback callback; in TEST_F() local
194 int rv = stream.Open(temp_file_path(), flags, callback.callback()); in TEST_F()
195 EXPECT_THAT(callback.GetResult(rv), IsOk()); in TEST_F()
203 rv = stream.Read(buf.get(), buf->size(), callback.callback()); in TEST_F()
204 rv = callback.GetResult(rv); in TEST_F()
223 TestCompletionCallback callback; in TEST_F() local
224 int rv = stream->Open(temp_file_path(), flags, callback.callback()); in TEST_F()
226 EXPECT_THAT(callback.WaitForResult(), IsOk()); in TEST_F()
230 rv = stream->Read(buf.get(), buf->size(), callback.callback()); in TEST_F()
234 // The callback should not be called if the request is cancelled. in TEST_F()
236 EXPECT_FALSE(callback.have_result()); in TEST_F()
249 TestCompletionCallback callback; in TEST_F() local
250 int rv = stream.Open(temp_file_path(), flags, callback.callback()); in TEST_F()
252 EXPECT_THAT(callback.WaitForResult(), IsOk()); in TEST_F()
256 rv = stream.Seek(kOffset, callback64.callback()); in TEST_F()
267 rv = stream.Read(buf.get(), buf->size(), callback.callback()); in TEST_F()
269 rv = callback.WaitForResult(); in TEST_F()
284 TestCompletionCallback callback; in TEST_F() local
285 int rv = stream.Open(temp_file_path(), flags, callback.callback()); in TEST_F()
286 EXPECT_THAT(callback.GetResult(rv), IsOk()); in TEST_F()
293 rv = stream.Write(buf.get(), kTestDataSize, callback.callback()); in TEST_F()
294 rv = callback.GetResult(rv); in TEST_F()
310 TestCompletionCallback callback; in TEST_F() local
311 int rv = stream->Open(temp_file_path(), flags, callback.callback()); in TEST_F()
313 EXPECT_THAT(callback.WaitForResult(), IsOk()); in TEST_F()
320 rv = stream->Write(buf.get(), buf->size(), callback.callback()); in TEST_F()
324 // The callback should not be called if the request is cancelled. in TEST_F()
326 EXPECT_FALSE(callback.have_result()); in TEST_F()
340 TestCompletionCallback callback; in TEST_F() local
341 int rv = stream.Open(temp_file_path(), flags, callback.callback()); in TEST_F()
343 EXPECT_THAT(callback.WaitForResult(), IsOk()); in TEST_F()
347 rv = stream.Seek(kOffset, callback64.callback()); in TEST_F()
360 callback.callback()); in TEST_F()
362 rv = callback.WaitForResult(); in TEST_F()
381 TestCompletionCallback callback; in TEST_F() local
382 int rv = stream->Open(temp_file_path(), flags, callback.callback()); in TEST_F()
384 EXPECT_THAT(callback.WaitForResult(), IsOk()); in TEST_F()
392 rv = stream->Read(buf.get(), buf->size(), callback.callback()); in TEST_F()
394 rv = callback.WaitForResult(); in TEST_F()
412 callback.callback()); in TEST_F()
414 rv = callback.WaitForResult(); in TEST_F()
436 TestCompletionCallback callback; in TEST_F() local
437 int rv = stream->Open(temp_file_path(), flags, callback.callback()); in TEST_F()
439 EXPECT_THAT(callback.WaitForResult(), IsOk()); in TEST_F()
442 rv = stream->Seek(file_size, callback64.callback()); in TEST_F()
455 callback.callback()); in TEST_F()
457 rv = callback.WaitForResult(); in TEST_F()
467 rv = stream->Seek(0, callback64.callback()); in TEST_F()
478 rv = stream->Read(buf.get(), buf->size(), callback.callback()); in TEST_F()
480 rv = callback.WaitForResult(); in TEST_F()
524 have_result_ = false; // auto-reset for next callback in WaitForResult()
528 CompletionOnceCallback callback() { in callback() function in net::__anon8631b4fd0211::TestWriteReadCompletionCallback
534 TestCompletionCallback callback; in ValidateWrittenData() local
539 rv = stream_->Read(buf.get(), buf->size(), callback.callback()); in ValidateWrittenData()
541 rv = callback.WaitForResult(); in ValidateWrittenData()
562 TestWriteReadCompletionCallback callback( in OnComplete() local
565 drainable_.get(), drainable_->BytesRemaining(), callback.callback()); in OnComplete()
567 rv = callback.WaitForResult(); in OnComplete()
574 EXPECT_THAT(stream_->Seek(0, callback64.callback()), in OnComplete()
606 int rv = stream->Open(temp_file_path(), flags, open_callback.callback()); in TEST_F()
611 EXPECT_THAT(stream->Seek(file_size, callback64.callback()), in TEST_F()
619 // `callback` can't outlive `stream`. in TEST_F()
620 TestWriteReadCompletionCallback callback(stream.get(), &total_bytes_written, in TEST_F() local
624 rv = stream->Write(buf.get(), buf->size(), callback.callback()); in TEST_F()
626 rv = callback.WaitForResult(); in TEST_F()
631 callback.ValidateWrittenData(); in TEST_F()
664 have_result_ = false; // auto-reset for next callback in WaitForResult()
668 CompletionOnceCallback callback() { in callback() function in net::__anon8631b4fd0211::TestWriteCloseCompletionCallback
683 TestWriteCloseCompletionCallback callback(stream_, &total_bytes_written); in OnComplete() local
685 drainable_.get(), drainable_->BytesRemaining(), callback.callback()); in OnComplete()
687 rv = callback.WaitForResult(); in OnComplete()
715 int rv = stream->Open(temp_file_path(), flags, open_callback.callback()); in TEST_F()
720 EXPECT_THAT(stream->Seek(file_size, callback64.callback()), in TEST_F()
726 // `callback` can't outlive `stream`. in TEST_F()
727 TestWriteCloseCompletionCallback callback(stream.get(), in TEST_F() local
730 rv = stream->Write(buf.get(), buf->size(), callback.callback()); in TEST_F()
732 total_bytes_written = callback.WaitForResult(); in TEST_F()
752 int rv = stream->Open(temp_file_path(), flags, open_callback.callback()); in TEST_F()
762 rv = stream2->Open(temp_file_path(), flags, open_callback2.callback()); in TEST_F()
786 TestCompletionCallback callback; in TEST_F() local
787 int rv = stream->Write(buf.get(), 1, callback.callback()); in TEST_F()
789 rv = callback.WaitForResult(); in TEST_F()
809 TestCompletionCallback callback; in TEST_F() local
810 int rv = stream->Read(buf.get(), 1, callback.callback()); in TEST_F()
812 rv = callback.WaitForResult(); in TEST_F()
833 TestCompletionCallback callback; in TEST_F() local
836 int rv = stream.Read(buf.get(), buf->size(), callback.callback()); in TEST_F()
837 EXPECT_THAT(callback.GetResult(rv), IsError(ERR_UNEXPECTED)); in TEST_F()
864 TestCompletionCallback callback; in TEST_F() local
865 int rv = stream.Open(path, flags, callback.callback()); in TEST_F()
867 EXPECT_THAT(callback.WaitForResult(), IsOk()); in TEST_F()
875 rv = stream.Read(buf.get(), buf->size(), callback.callback()); in TEST_F()
877 rv = callback.WaitForResult(); in TEST_F()