Make Response::body return v8-extra based stream behind flag

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

Index: third_party/WebKit/Source/modules/fetch/FetchRequestData.cpp
diff --git a/third_party/WebKit/Source/modules/fetch/FetchRequestData.cpp b/third_party/WebKit/Source/modules/fetch/FetchRequestData.cpp
index 83ed19bc675025aa8a4846565649ac9df9eb2457..99c69b004fcce6a526a044f05b32bae6cfc67cbf 100644
--- a/third_party/WebKit/Source/modules/fetch/FetchRequestData.cpp
+++ b/third_party/WebKit/Source/modules/fetch/FetchRequestData.cpp
@@ -4,6 +4,7 @@
 
 #include "modules/fetch/FetchRequestData.h"
 
+#include "bindings/core/v8/ScriptState.h"
 #include "core/dom/ExecutionContext.h"
 #include "core/fetch/ResourceLoaderOptions.h"
 #include "core/loader/ThreadableLoader.h"
@@ -26,7 +27,7 @@ FetchRequestData* FetchRequestData::create()
     return new FetchRequestData();
 }
 
-FetchRequestData* FetchRequestData::create(ExecutionContext* executionContext, const WebServiceWorkerRequest& webRequest)
+FetchRequestData* FetchRequestData::create(ScriptState* scriptState, const WebServiceWorkerRequest& webRequest)
 {
     FetchRequestData* request = FetchRequestData::create();
     request->m_url = webRequest.url();
@@ -34,7 +35,7 @@ FetchRequestData* FetchRequestData::create(ExecutionContext* executionContext, c
     for (HTTPHeaderMap::const_iterator it = webRequest.headers().begin(); it != webRequest.headers().end(); ++it)
         request->m_headerList->append(it->key, it->value);
     if (webRequest.blobDataHandle())
-        request->setBuffer(new BodyStreamBuffer(FetchBlobDataConsumerHandle::create(executionContext, webRequest.blobDataHandle())));
+        request->setBuffer(new BodyStreamBuffer(scriptState, FetchBlobDataConsumerHandle::create(scriptState->getExecutionContext(), webRequest.blobDataHandle())));
     request->setContext(webRequest.requestContext());
     request->setReferrer(Referrer(webRequest.referrerUrl().string(), static_cast<ReferrerPolicy>(webRequest.referrerPolicy())));
     request->setMode(webRequest.mode());
@@ -65,25 +66,25 @@ FetchRequestData* FetchRequestData::cloneExceptBody()
     return request;
 }
 
-FetchRequestData* FetchRequestData::clone(ExecutionContext* executionContext)
+FetchRequestData* FetchRequestData::clone(ScriptState* scriptState)
 {
     FetchRequestData* request = FetchRequestData::cloneExceptBody();
     if (m_buffer) {
         OwnPtr<FetchDataConsumerHandle> dest1, dest2;
-        DataConsumerTee::create(executionContext, m_buffer->releaseHandle(executionContext), &dest1, &dest2);
-        m_buffer = new BodyStreamBuffer(dest1.release());
-        request->m_buffer = new BodyStreamBuffer(dest2.release());
+        DataConsumerTee::create(scriptState->getExecutionContext(), m_buffer->releaseHandle(), &dest1, &dest2);
+        m_buffer = new BodyStreamBuffer(scriptState, dest1.release());
+        request->m_buffer = new BodyStreamBuffer(scriptState, dest2.release());
     }
     return request;
 }
 
-FetchRequestData* FetchRequestData::pass(ExecutionContext* executionContext)
+FetchRequestData* FetchRequestData::pass(ScriptState* scriptState)
 {
     FetchRequestData* request = FetchRequestData::cloneExceptBody();
     if (m_buffer) {
         request->m_buffer = m_buffer;
-        m_buffer = new BodyStreamBuffer(createFetchDataConsumerHandleFromWebHandle(createDoneDataConsumerHandle()));
-        m_buffer->stream()->setIsDisturbed();
+        m_buffer = new BodyStreamBuffer(scriptState, createFetchDataConsumerHandleFromWebHandle(createDoneDataConsumerHandle()));
+        m_buffer->setDisturbed();
     }
     return request;
 }