PROTOTYPE: PlzNavigate: use a Mojo data pipe to stream navigation data to the renderer.

content/browser/loader/navigation_url_loader_unittest.cc

 // Copyright 2014 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 <utility>
 
 #include "base/command_line.h"
 #include "base/macros.h"
 #include "base/memory/ref_counted.h"
 #include "base/memory/scoped_ptr.h"
@@ skipping 91 matching lines @@
   // NavigationURLLoaderDelegate implementation.
   void OnRequestRedirected(
       const net::RedirectInfo& redirect_info,
       const scoped_refptr<ResourceResponse>& response) override {
     redirect_info_ = redirect_info;
     redirect_response_ = response;
     ASSERT_TRUE(request_redirected_);
     request_redirected_->Quit();
   }
 
-  void OnResponseStarted(const scoped_refptr<ResourceResponse>& response,
-                         scoped_ptr<StreamHandle> body) override {
+  void OnResponseStarted(
+      const scoped_refptr<ResourceResponse>& response,
+      scoped_ptr<StreamHandle> body,
+      mojo::ScopedDataPipeConsumerHandle data_consumer_handle) override {
     response_ = response;
     body_ = std::move(body);
+    data_consumer_handle_ = std::move(data_consumer_handle);
     ASSERT_TRUE(response_started_);
     response_started_->Quit();
   }
 
   void OnRequestFailed(bool in_cache, int net_error) override {
     net_error_ = net_error;
     ASSERT_TRUE(request_failed_);
     request_failed_->Quit();
   }
 
   void OnRequestStarted(base::TimeTicks timestamp) override {
     ASSERT_FALSE(timestamp.is_null());
     ++on_request_handled_counter_;
   }
 
  private:
   net::RedirectInfo redirect_info_;
   scoped_refptr<ResourceResponse> redirect_response_;
   scoped_refptr<ResourceResponse> response_;
   scoped_ptr<StreamHandle> body_;
+  mojo::ScopedDataPipeConsumerHandle data_consumer_handle_;
   int net_error_;
   int on_request_handled_counter_;
 
   scoped_ptr<base::RunLoop> request_redirected_;
   scoped_ptr<base::RunLoop> response_started_;
   scoped_ptr<base::RunLoop> request_failed_;
 };
 
 class RequestBlockingResourceDispatcherHostDelegate
     : public ResourceDispatcherHostDelegate {
@@ skipping 251 matching lines @@
 
   // Release the body.
   delegate.ReleaseBody();
   base::RunLoop().RunUntilIdle();
 
   // Verify that URLRequestTestJob no longer has anything paused.
   EXPECT_FALSE(net::URLRequestTestJob::ProcessOnePendingMessage());
 }
 
 }  // namespace content