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

third_party/WebKit/Source/modules/fetch/ReadableStreamDataConsumerHandle.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/ReadableStreamDataConsumerHandle.h"
 
 #include "bindings/core/v8/ExceptionState.h"
 #include "bindings/core/v8/ScopedPersistent.h"
 #include "bindings/core/v8/ScriptFunction.h"
 #include "bindings/core/v8/ScriptState.h"
 #include "bindings/core/v8/ScriptValue.h"
 #include "bindings/core/v8/V8BindingMacros.h"
 #include "bindings/core/v8/V8IteratorResultValue.h"
 #include "bindings/core/v8/V8Uint8Array.h"
 #include "bindings/core/v8/WorkerOrWorkletScriptController.h"
 #include "core/dom/DOMTypedArray.h"
+#include "core/dom/TaskRunnerHelper.h"
 #include "core/streams/ReadableStreamOperations.h"
 #include "core/workers/WorkerGlobalScope.h"
 #include "public/platform/Platform.h"
 #include "public/platform/WebTaskRunner.h"
 #include "public/platform/WebThread.h"
 #include "public/platform/WebTraceLocation.h"
 #include "wtf/Assertions.h"
 #include "wtf/Functional.h"
 #include "wtf/RefCounted.h"
 #include <algorithm>
@@ skipping 207 matching lines @@
 
     void notify()
     {
         if (!m_client)
             return;
         m_client->didGetReadable();
     }
 
     void notifyLater()
     {
-        ASSERT(m_client);
-        Platform::current()->currentThread()->getWebTaskRunner()->postTask(BLINK_FROM_HERE, WTF::bind(&ReadingContext::notify, PassRefPtr<ReadingContext>(this)));
+        if (!m_client)
+            return;
+        TaskRunnerHelper::getUnthrottledTaskRunner(m_scriptState.get())->postTask(BLINK_FROM_HERE, WTF::bind(&ReadingContext::notify, PassRefPtr<ReadingContext>(this)));
     }
 
 private:
     ReadingContext(ScriptState* scriptState, ScriptValue streamReader)
         : m_reader(scriptState->isolate(), streamReader.v8Value())
         , m_scriptState(scriptState)
         , m_client(nullptr)
         , m_pendingOffset(0)
         , m_isReading(false)
         , m_isDone(false)
         , m_hasError(false)
     {
         m_reader.setWeak(this, &ReadingContext::onCollected);
     }
 
     void onCollected()
     {
         m_reader.clear();
         if (m_isDone || m_hasError)
             return;
         m_hasError = true;
-        if (m_client)
-            notifyLater();
+        notifyLater();
     }
 
     static void onCollected(const v8::WeakCallbackInfo<ReadableStreamDataConsumerHandle::ReadingContext>& data)
     {
         data.GetParameter()->onCollected();
     }
 
     // |m_reader| is a weak persistent. It should be kept alive by someone
     // outside of ReadableStreamDataConsumerHandle.
     // Holding a ScopedPersistent here is safe in terms of cross-world wrapper
@@ skipping 13 matching lines @@
 {
 }
 ReadableStreamDataConsumerHandle::~ReadableStreamDataConsumerHandle() = default;
 
 std::unique_ptr<FetchDataConsumerHandle::Reader> ReadableStreamDataConsumerHandle::obtainFetchDataReader(Client* client)
 {
     return WTF::wrapUnique(new ReadingContext::ReaderImpl(m_readingContext, client));
 }
 
 } // namespace blink