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

third_party/WebKit/Source/modules/cachestorage/Cache.cpp

Index: third_party/WebKit/Source/modules/cachestorage/Cache.cpp
diff --git a/third_party/WebKit/Source/modules/cachestorage/Cache.cpp b/third_party/WebKit/Source/modules/cachestorage/Cache.cpp
index 1ec10966bd64c9cf798c662a3f088b047ea67c07..316101c7ca7f386f64d29c72f18e9c187a1195a2 100644
--- a/third_party/WebKit/Source/modules/cachestorage/Cache.cpp
+++ b/third_party/WebKit/Source/modules/cachestorage/Cache.cpp
@@ -12,6 +12,7 @@
 #include "bindings/core/v8/V8ThrowException.h"
 #include "bindings/modules/v8/V8Response.h"
 #include "core/dom/DOMException.h"
+#include "core/dom/TaskRunnerHelper.h"
 #include "core/inspector/ConsoleMessage.h"
 #include "modules/cachestorage/CacheStorageError.h"
 #include "modules/fetch/BodyStreamBuffer.h"
@@ -307,6 +308,11 @@ public:
         m_resolver->reject(V8ThrowException::createTypeError(state->isolate(), errorMessage));
     }
 
+    ScriptPromiseResolver* resolver()
+    {
+        return m_resolver;
+    }
+
     DEFINE_INLINE_VIRTUAL_TRACE()
     {
         visitor->trace(m_cache);
@@ -348,6 +354,11 @@ public:
         m_barrierCallback->onError("network error");
     }
 
+    WebTaskRunner* getTaskRunner() override
+    {
+        return TaskRunnerHelper::getUnthrottledTaskRunner(m_barrierCallback->resolver()->getExecutionContext());
+    }
+
     DEFINE_INLINE_VIRTUAL_TRACE()
     {
         visitor->trace(m_barrierCallback);