Index: third_party/WebKit/Source/modules/fetch/ReadableStreamDataConsumerHandle.cpp |
diff --git a/third_party/WebKit/Source/modules/fetch/ReadableStreamDataConsumerHandle.cpp b/third_party/WebKit/Source/modules/fetch/ReadableStreamDataConsumerHandle.cpp |
index ca69f165054155930f38448de3f1a78276f13cf0..9f4533ad514c5ac482bb27c05f6c8d198f62af4e 100644 |
--- a/third_party/WebKit/Source/modules/fetch/ReadableStreamDataConsumerHandle.cpp |
+++ b/third_party/WebKit/Source/modules/fetch/ReadableStreamDataConsumerHandle.cpp |
@@ -12,10 +12,8 @@ |
#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/streams/ReadableStreamOperations.h" |
-#include "core/workers/WorkerGlobalScope.h" |
#include "public/platform/Platform.h" |
#include "public/platform/WebTaskRunner.h" |
#include "public/platform/WebThread.h" |
@@ -29,20 +27,6 @@ |
namespace blink { |
-namespace { |
- |
-bool isTerminating(ScriptState* scriptState) |
-{ |
- ExecutionContext* executionContext = scriptState->getExecutionContext(); |
- if (!executionContext) |
- return true; |
- if (!executionContext->isWorkerGlobalScope()) |
- return false; |
- return toWorkerGlobalScope(executionContext)->scriptController()->isExecutionTerminating(); |
-} |
- |
-} // namespace |
- |
using Result = WebDataConsumerHandle::Result; |
using Flags = WebDataConsumerHandle::Flags; |
@@ -65,11 +49,7 @@ public: |
bool done; |
v8::Local<v8::Value> item = v.v8Value(); |
ASSERT(item->IsObject()); |
- if (isTerminating(v.getScriptState())) |
- return ScriptValue(); |
v8::MaybeLocal<v8::Value> maybeValue = v8UnpackIteratorResult(v.getScriptState(), item.As<v8::Object>(), &done); |
- if (isTerminating(v.getScriptState())) |
- return ScriptValue(); |
v8::Local<v8::Value> value = maybeValue.ToLocalChecked(); |
if (done) { |
readingContext->onReadDone(); |