Implement ReadableStreamBytesConsumer

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

 // Copyright 2014 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/Response.h"
 
 #include "bindings/core/v8/Dictionary.h"
 #include "bindings/core/v8/ExceptionState.h"
 #include "bindings/core/v8/ScriptState.h"
 #include "bindings/core/v8/V8ArrayBuffer.h"
 #include "bindings/core/v8/V8ArrayBufferView.h"
 #include "bindings/core/v8/V8Binding.h"
 #include "bindings/core/v8/V8Blob.h"
 #include "bindings/core/v8/V8FormData.h"
 #include "bindings/core/v8/V8HiddenValue.h"
 #include "bindings/core/v8/V8URLSearchParams.h"
 #include "core/dom/DOMArrayBuffer.h"
 #include "core/dom/DOMArrayBufferView.h"
 #include "core/dom/URLSearchParams.h"
 #include "core/fileapi/Blob.h"
 #include "core/html/FormData.h"
 #include "core/streams/ReadableStreamOperations.h"
 #include "modules/fetch/BlobBytesConsumer.h"
 #include "modules/fetch/BodyStreamBuffer.h"
 #include "modules/fetch/DataConsumerHandleUtil.h"
 #include "modules/fetch/FormDataBytesConsumer.h"
-#include "modules/fetch/ReadableStreamDataConsumerHandle.h"
 #include "modules/fetch/ResponseInit.h"
 #include "platform/network/EncodedFormData.h"
 #include "platform/network/HTTPHeaderMap.h"
 #include "public/platform/modules/serviceworker/WebServiceWorkerResponse.h"
 #include "wtf/RefPtr.h"
 #include <memory>
 
 namespace blink {
 
 namespace {
@@ skipping 137 matching lines @@
       return nullptr;
     bodyBuffer =
         new BodyStreamBuffer(scriptState, new FormDataBytesConsumer(string));
     contentType = "text/plain;charset=UTF-8";
   }
   Response* response =
       create(scriptState, bodyBuffer, contentType,
              ResponseInit(init, exceptionState), exceptionState);
   if (!exceptionState.hadException() && !reader.isEmpty()) {
     // Add a hidden reference so that the weak persistent in the
-    // ReadableStreamDataConsumerHandle will be valid as long as the
+    // ReadableStreamBytesConsumer will be valid as long as the
     // Response is valid.
     v8::Local<v8::Value> wrapper = toV8(response, scriptState);
     if (wrapper.IsEmpty()) {
       exceptionState.throwTypeError("Cannot create a Response wrapper");
       return nullptr;
     }
     ASSERT(wrapper->IsObject());
     V8HiddenValue::setHiddenValue(
         scriptState, wrapper.As<v8::Object>(),
         V8HiddenValue::readableStreamReaderInResponse(scriptState->isolate()),
@@ skipping 267 matching lines @@
       V8HiddenValue::internalBodyBuffer(scriptState->isolate()), bodyBuffer);
 }
 
 DEFINE_TRACE(Response) {
   Body::trace(visitor);
   visitor->trace(m_response);
   visitor->trace(m_headers);
 }
 
 }  // namespace blink