Implement ReadableStreamBytesConsumer

third_party/WebKit/Source/modules/fetch/BodyStreamBuffer.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/BodyStreamBuffer.h"
 
 #include "bindings/core/v8/ScriptState.h"
 #include "bindings/core/v8/V8HiddenValue.h"
 #include "core/dom/DOMArrayBuffer.h"
 #include "core/dom/DOMTypedArray.h"
 #include "core/dom/ExceptionCode.h"
 #include "core/streams/ReadableStreamController.h"
 #include "core/streams/ReadableStreamOperations.h"
 #include "modules/fetch/Body.h"
 #include "modules/fetch/BytesConsumerForDataConsumerHandle.h"
 #include "modules/fetch/DataConsumerHandleUtil.h"
-#include "modules/fetch/ReadableStreamDataConsumerHandle.h"
+#include "modules/fetch/ReadableStreamBytesConsumer.h"
 #include "platform/blob/BlobData.h"
 #include "platform/network/EncodedFormData.h"
 #include <memory>
 
 namespace blink {
 
 class BodyStreamBuffer::LoaderClient final
     : public GarbageCollectedFinalized<LoaderClient>,
       public ActiveDOMObject,
       public FetchDataLoader::Client {
@@ skipping 337 matching lines @@
     ScriptState::Scope scope(m_scriptState.get());
     // We need to have |reader| alive by some means (as written in
     // ReadableStreamDataConsumerHandle). Based on the following facts
     //  - This function is used only from tee and startLoading.
     //  - This branch cannot be taken when called from tee.
     //  - startLoading makes hasPendingActivity return true while loading.
     // , we don't need to keep the reader explicitly.
     NonThrowableExceptionState exceptionState;
     ScriptValue reader = ReadableStreamOperations::getReader(
         m_scriptState.get(), stream(), exceptionState);
-    return new BytesConsumerForDataConsumerHandle(
-        m_scriptState->getExecutionContext(),
-        ReadableStreamDataConsumerHandle::create(m_scriptState.get(), reader));
+    return new ReadableStreamBytesConsumer(m_scriptState.get(), reader);
   }
   // We need to call these before calling closeAndLockAndDisturb.
   const bool isClosed = isStreamClosed();
   const bool isErrored = isStreamErrored();
   BytesConsumer* consumer = m_consumer.release();
 
   closeAndLockAndDisturb();
 
   if (isClosed) {
     // Note that the stream cannot be "draining", because it doesn't have
     // the internal buffer.
     return new BytesConsumerForDataConsumerHandle(
         m_scriptState->getExecutionContext(),
         createFetchDataConsumerHandleFromWebHandle(
             createDoneDataConsumerHandle()));
   }
   if (isErrored)
     return new BytesConsumerForDataConsumerHandle(
         m_scriptState->getExecutionContext(),
         createFetchDataConsumerHandleFromWebHandle(
             createUnexpectedErrorDataConsumerHandle()));
 
   DCHECK(consumer);
   consumer->clearClient();
   return consumer;
 }
 
 }  // namespace blink