Use ByteStream in downloads system to decouple source and sink.

net/url_request/url_request_test_job.cc

Index: net/url_request/url_request_test_job.cc
diff --git a/net/url_request/url_request_test_job.cc b/net/url_request/url_request_test_job.cc
index 4a0ba6e21291ca62a345ff57ca84526eefd59129..d501d0b7d2411acfda4fc11704ad033b87e95504 100644
--- a/net/url_request/url_request_test_job.cc
+++ b/net/url_request/url_request_test_job.cc
@@ -247,7 +247,12 @@ void URLRequestTestJob::ProcessNextOperation() {
         if (!ReadRawData(async_buf_, async_buf_size_, &bytes_read))
           NOTREACHED() << "This should not return false in DATA_AVAILABLE.";
         SetStatus(URLRequestStatus());  // clear the io pending flag
+        if (FinalRoundIOPending()) {
+          // Make any nested read calls return IO_PENDING.
+          stage_ = WAITING;
+        }
         NotifyReadComplete(bytes_read);
+        stage_ = DATA_AVAILABLE;
       }
       break;
     case DATA_AVAILABLE:
@@ -265,6 +270,10 @@ void URLRequestTestJob::ProcessNextOperation() {
   }
 }
 
+bool URLRequestTestJob::FinalRoundIOPending() {
+  return false;
+}
+
 void URLRequestTestJob::AdvanceJob() {
   if (auto_advance_) {
     MessageLoop::current()->PostTask(