Use ByteStream in downloads system to decouple source and sink.

content/test/net/url_request_slow_download_job.cc

 // Copyright (c) 2012 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include "content/test/net/url_request_slow_download_job.h"
 
 #include "base/bind.h"
 #include "base/compiler_specific.h"
 #include "base/logging.h"
 #include "base/message_loop.h"
@@ skipping 167 matching lines @@
 }
 
 void URLRequestSlowDownloadJob::CheckDoneStatus() {
   if (should_finish_download_) {
     VLOG(10) << __FUNCTION__ << " called w/ should_finish_download_ set.";
     DCHECK(NULL != buffer_);
     int bytes_written = 0;
     ReadStatus status = FillBufferHelper(buffer_, buffer_size_, &bytes_written);
     DCHECK_EQ(BUFFER_FILLED, status);
     SetStatus(net::URLRequestStatus());
+    // Release reference
+    buffer_ = NULL;

[Randy Smith (Not in Mondays), 2012/05/19 15:29:57]

This has already landed, and will disappear from this CL when I next merge.
 

[Randy Smith (Not in Mondays), 2012/05/23 03:33:15]

Done.

     NotifyReadComplete(bytes_written);
   } else {
     MessageLoop::current()->PostDelayedTask(
         FROM_HERE,
         base::Bind(&URLRequestSlowDownloadJob::CheckDoneStatus,
                    weak_factory_.GetWeakPtr()),
         base::TimeDelta::FromMilliseconds(100));
   }
 }
 
@@ skipping 34 matching lines @@
   // ParseRawHeaders expects \0 to end each header line.
   ReplaceSubstringsAfterOffset(&raw_headers, 0, "\n", std::string("\0", 1));
   info->headers = new net::HttpResponseHeaders(raw_headers);
 }
 
 bool URLRequestSlowDownloadJob::GetMimeType(std::string* mime_type) const {
   net::HttpResponseInfo info;
   GetResponseInfoConst(&info);
   return info.headers && info.headers->GetMimeType(mime_type);
 }