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.

[rvargas (doing something else), 2012/05/29 18:13:36]

This actually requires nested read calls for it to work. Maybe add that
somewhere to this class documentation. (although that would be documenting a
feature that is not directly supported by this class... but the derived class
(and related tests) should be aware of it).

[Randy Smith (Not in Mondays), 2012/05/30 00:22:32]

I renamed the upcall and changed it's semantics to be defined in terms of the
state transition; let me know if you like this better.

+          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(