Implement BlobBytesConsumer

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

Index: third_party/WebKit/Source/modules/fetch/BytesConsumer.cpp
diff --git a/third_party/WebKit/Source/modules/fetch/BytesConsumer.cpp b/third_party/WebKit/Source/modules/fetch/BytesConsumer.cpp
index e003f2a2aebe7e8cc185cb3d8c5fb418e2a62305..a0c3aee594d64704f0f90ff3a8d725b95fa38ce9 100644
--- a/third_party/WebKit/Source/modules/fetch/BytesConsumer.cpp
+++ b/third_party/WebKit/Source/modules/fetch/BytesConsumer.cpp
@@ -6,7 +6,7 @@
 
 #include "core/dom/ExecutionContext.h"
 #include "core/dom/TaskRunnerHelper.h"
-#include "modules/fetch/BytesConsumerForDataConsumerHandle.h"
+#include "modules/fetch/BlobBytesConsumer.h"
 #include "modules/fetch/FetchBlobDataConsumerHandle.h"
 #include "platform/blob/BlobData.h"
 #include "public/platform/WebTaskRunner.h"
@@ -332,9 +332,8 @@ void BytesConsumer::tee(ExecutionContext* executionContext, BytesConsumer* src,
     if (blobDataHandle) {
         // Register a client in order to be consistent.
         src->setClient(new NoopClient);
-        // TODO(yhirano): Do not use FetchBlobDataConsumerHandle.
-        *dest1 = new BytesConsumerForDataConsumerHandle(executionContext, FetchBlobDataConsumerHandle::create(executionContext, blobDataHandle));
-        *dest2 = new BytesConsumerForDataConsumerHandle(executionContext, FetchBlobDataConsumerHandle::create(executionContext, blobDataHandle));
+        *dest1 = new BlobBytesConsumer(executionContext, blobDataHandle);
+        *dest2 = new BlobBytesConsumer(executionContext, blobDataHandle);
         return;
     }