Handle MOJO_RESULT_BUSY result in URLResponseBodyConsumer

content/child/resource_dispatcher.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.
 
 // See http://dev.chromium.org/developers/design-documents/multi-process-resource-loading
 
 #include "content/child/resource_dispatcher.h"
 
 #include <utility>
 
@@ skipping 77 matching lines @@
   ~URLLoaderClientImpl() override {
     if (body_consumer_)
       body_consumer_->Cancel();
   }
 
   void OnReceiveResponse(
       const ResourceResponseHead& response_head,
       mojom::DownloadedTempFilePtr downloaded_file) override {
     has_received_response_ = true;
     if (body_consumer_)
-      body_consumer_->Start(task_runner_.get());
+      body_consumer_->Start();
     downloaded_file_ = std::move(downloaded_file);
     resource_dispatcher_->OnMessageReceived(
         ResourceMsg_ReceivedResponse(request_id_, response_head));
   }
 
   void OnReceiveRedirect(const net::RedirectInfo& redirect_info,
                          const ResourceResponseHead& response_head) override {
     DCHECK(!has_received_response_);
     DCHECK(!body_consumer_);
     resource_dispatcher_->OnMessageReceived(ResourceMsg_ReceivedRedirect(
         request_id_, redirect_info, response_head));
   }
 
   void OnDataDownloaded(int64_t data_len, int64_t encoded_data_len) override {
     resource_dispatcher_->OnMessageReceived(
         ResourceMsg_DataDownloaded(request_id_, data_len, encoded_data_len));
   }
 
   void OnStartLoadingResponseBody(
       mojo::ScopedDataPipeConsumerHandle body) override {
     DCHECK(!body_consumer_);
     body_consumer_ = new URLResponseBodyConsumer(
         request_id_, resource_dispatcher_, std::move(body), task_runner_);
     if (has_received_response_)
-      body_consumer_->Start(task_runner_.get());
+      body_consumer_->Start();
   }
 
   void OnComplete(const ResourceRequestCompletionStatus& status) override {
     if (!body_consumer_) {
       resource_dispatcher_->OnMessageReceived(
           ResourceMsg_RequestComplete(request_id_, status));
       return;
     }
     body_consumer_->OnComplete(status);
   }
@@ skipping 727 matching lines @@
     delete message;
   }
 }
 
 void ResourceDispatcher::SetResourceSchedulingFilter(
     scoped_refptr<ResourceSchedulingFilter> resource_scheduling_filter) {
   resource_scheduling_filter_ = resource_scheduling_filter;
 }
 
 }  // namespace content