Use per-frame TaskRunner instead of thread's default in DataConsumerHandle

content/child/web_data_consumer_handle_impl_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 "content/child/web_data_consumer_handle_impl.h"
 
 #include <stddef.h>
 #include <stdint.h>
 
 #include <algorithm>
 #include <memory>
 #include <string>
 #include <utility>
 
 #include "base/bind.h"
 #include "base/location.h"
 #include "base/memory/ptr_util.h"
 #include "base/run_loop.h"
 #include "base/single_thread_task_runner.h"
 #include "base/synchronization/waitable_event.h"
 #include "base/threading/thread.h"
 #include "base/threading/thread_task_runner_handle.h"
 #include "mojo/public/cpp/system/data_pipe.h"
 #include "testing/gtest/include/gtest/gtest.h"
+#include "third_party/WebKit/public/platform/WebTaskRunner.h"
 
 namespace content {
 
 namespace {
 
 using blink::WebDataConsumerHandle;
 
 class ReadDataOperationBase {
  public:
   virtual ~ReadDataOperationBase() {}
@@ skipping 37 matching lines @@
 
   void ReadMore() override {
     // We may have drained the pipe while this task was waiting to run.
     if (reader_)
       ReadData();
   }
 
   void ReadData() {
     if (!client_) {
       client_.reset(new ClientImpl(this));
-      reader_ = handle_->obtainReader(client_.get());
+      reader_ = handle_->obtainReader(client_.get(), nullptr);
     }
 
     Result rv = kOk;
     size_t readSize = 0;
     while (true) {
       char buffer[16];
       rv = reader_->read(&buffer, sizeof(buffer), kNone, &readSize);
       if (rv != kOk)
         break;
       result_.insert(result_.size(), &buffer[0], readSize);
@@ skipping 37 matching lines @@
 
   void ReadMore() override {
     // We may have drained the pipe while this task was waiting to run.
     if (reader_)
       ReadData();
   }
 
   void ReadData() {
     if (!client_) {
       client_.reset(new ClientImpl(this));
-      reader_ = handle_->obtainReader(client_.get());
+      reader_ = handle_->obtainReader(client_.get(), nullptr);
     }
 
     Result rv;
     while (true) {
       const void* buffer = nullptr;
       size_t size;
       rv = reader_->beginRead(&buffer, kNone, &size);
       if (rv != kOk)
         break;
       // In order to verify endRead, we read at most one byte for each time.
@@ skipping 121 matching lines @@
 
   run_loop.Run();
   t.Stop();
 
   EXPECT_EQ(expected, operation->result());
 }
 
 }  // namespace
 
 }  // namespace content