Implement ReadableStreamBytesConsumer

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

Index: third_party/WebKit/Source/modules/fetch/BodyStreamBuffer.cpp
diff --git a/third_party/WebKit/Source/modules/fetch/BodyStreamBuffer.cpp b/third_party/WebKit/Source/modules/fetch/BodyStreamBuffer.cpp
index d9a86e010a05913a18f725e1d88cb8b44ab054ea..87ba6a56bcd1c75241d1386e559a6c04ce19fcdf 100644
--- a/third_party/WebKit/Source/modules/fetch/BodyStreamBuffer.cpp
+++ b/third_party/WebKit/Source/modules/fetch/BodyStreamBuffer.cpp
@@ -14,7 +14,7 @@
 #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>
@@ -372,9 +372,7 @@ BytesConsumer* BodyStreamBuffer::releaseHandle() {
     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();