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

third_party/WebKit/Source/modules/fetch/FetchDataLoader.cpp

 // Copyright 2015 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 "modules/fetch/FetchDataLoader.h"
 
 #include "core/html/parser/TextResourceDecoder.h"
 #include "wtf/PtrUtil.h"
 #include "wtf/text/StringBuilder.h"
 #include "wtf/text/WTFString.h"
@@ skipping 78 matching lines @@
             case WebDataConsumerHandle::UnexpectedError:
                 m_reader.reset();
                 m_blobData.reset();
                 m_client->didFetchDataLoadFailed();
                 m_client.clear();
                 return;
             }
         }
     }
 
+    WebTaskRunner* getTaskRunner() override
+    {
+        return m_client->getTaskRunner();
+    }
+
     void cancel() override
     {
         m_reader.reset();
         m_blobData.reset();
         m_client.clear();
     }
 
     std::unique_ptr<FetchDataConsumerHandle::Reader> m_reader;
     Member<FetchDataLoader::Client> m_client;
 
@@ skipping 62 matching lines @@
 
             case WebDataConsumerHandle::Busy:
             case WebDataConsumerHandle::ResourceExhausted:
             case WebDataConsumerHandle::UnexpectedError:
                 error();
                 return;
             }
         }
     }
 
+    WebTaskRunner* getTaskRunner() override
+    {
+        return m_client->getTaskRunner();
+    }
+
     void error()
     {
         m_reader.reset();
         m_rawData.reset();
         m_client->didFetchDataLoadFailed();
         m_client.clear();
     }
 
     void cancel() override
     {
@@ skipping 64 matching lines @@
 
             case WebDataConsumerHandle::Busy:
             case WebDataConsumerHandle::ResourceExhausted:
             case WebDataConsumerHandle::UnexpectedError:
                 error();
                 return;
             }
         }
     }
 
+    WebTaskRunner* getTaskRunner() override
+    {
+        return m_client->getTaskRunner();
+    }
+
     void error()
     {
         m_reader.reset();
         m_builder.clear();
         m_decoder.reset();
         m_client->didFetchDataLoadFailed();
         m_client.clear();
     }
 
     void cancel() override
@@ skipping 77 matching lines @@
                 // process.
                 m_reader.reset();
                 m_outStream->abort();
                 m_client->didFetchDataLoadFailed();
                 cleanup();
                 return;
             }
         }
     }
 
+    WebTaskRunner* getTaskRunner() override
+    {
+        return m_client->getTaskRunner();
+    }
+
     void cancel() override
     {
         cleanup();
     }
 
     void cleanup()
     {
         m_reader.reset();
         m_client.clear();
         m_outStream.clear();
@@ skipping 22 matching lines @@
 {
     return new FetchDataLoaderAsString();
 }
 
 FetchDataLoader* FetchDataLoader::createLoaderAsStream(Stream* outStream)
 {
     return new FetchDataLoaderAsStream(outStream);
 }
 
 } // namespace blink