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..0798e69950b75829412662a21ccf5a9c120defe5 100644
--- a/net/url_request/url_request_test_job.cc
+++ b/net/url_request/url_request_test_job.cc
@@ -247,6 +247,11 @@ 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 (NextReadAsync()) {
+          // Make all future results return io pending until the next

[rvargas (doing something else), 2012/05/30 00:49:03]

nit: results -> something else. "Operations" maybe?

[Randy Smith (Not in Mondays), 2012/05/30 19:36:43]

I went for "reads", which seemed most precise.

+          // ProcessNextOperation().
+          stage_ = WAITING;
+        }
         NotifyReadComplete(bytes_read);
       }
       break;
@@ -265,6 +270,10 @@ void URLRequestTestJob::ProcessNextOperation() {
   }
 }
 
+bool URLRequestTestJob::NextReadAsync() {
+  return false;
+}
+
 void URLRequestTestJob::AdvanceJob() {
   if (auto_advance_) {
     MessageLoop::current()->PostTask(