Remove create[Done|UnexpectedError]DataConsumerHandle

third_party/WebKit/Source/modules/fetch/ResponseTest.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/ExceptionState.h"
 #include "bindings/core/v8/ScriptState.h"
 #include "bindings/core/v8/V8BindingForTesting.h"
 #include "core/dom/Document.h"
 #include "core/frame/Frame.h"
 #include "core/testing/DummyPageHolder.h"
 #include "modules/fetch/BodyStreamBuffer.h"
+#include "modules/fetch/BytesConsumer.h"
 #include "modules/fetch/BytesConsumerTestUtil.h"
 #include "modules/fetch/DataConsumerHandleTestUtil.h"
 #include "modules/fetch/DataConsumerHandleUtil.h"
 #include "modules/fetch/FetchResponseData.h"
 #include "platform/blob/BlobData.h"
 #include "platform/testing/UnitTestHelpers.h"
 #include "public/platform/modules/serviceworker/WebServiceWorkerResponse.h"
 #include "testing/gtest/include/gtest/gtest.h"
 #include "wtf/PtrUtil.h"
 #include <memory>
@@ skipping 177 matching lines @@
   EXPECT_CALL(*client2, didFetchDataLoadedString(String("Hello, world")));
 
   response->internalBodyBuffer()->startLoading(
       FetchDataLoader::createLoaderAsString(), client1);
   clonedResponse->internalBodyBuffer()->startLoading(
       FetchDataLoader::createLoaderAsString(), client2);
   blink::testing::runPendingTasks();
 }
 
 BodyStreamBuffer* createHelloWorldBuffer(ScriptState* scriptState) {
-  using Command = DataConsumerHandleTestUtil::Command;
-  std::unique_ptr<DataConsumerHandleTestUtil::ReplayingHandle> src(
-      DataConsumerHandleTestUtil::ReplayingHandle::create());
+  using Command = BytesConsumerTestUtil::Command;
+  BytesConsumerTestUtil::ReplayingBytesConsumer* src =
+      new BytesConsumerTestUtil::ReplayingBytesConsumer(
+          scriptState->getExecutionContext());
   src->add(Command(Command::Data, "Hello, "));
   src->add(Command(Command::Data, "world"));
   src->add(Command(Command::Done));
-  return new BodyStreamBuffer(
-      scriptState, createFetchDataConsumerHandleFromWebHandle(std::move(src)));
+  return new BodyStreamBuffer(scriptState, src);
 }
 
 TEST(ServiceWorkerResponseTest, BodyStreamBufferCloneDefault) {
   V8TestingScope scope;
   BodyStreamBuffer* buffer = createHelloWorldBuffer(scope.getScriptState());
   FetchResponseData* fetchResponseData =
       FetchResponseData::createWithBuffer(buffer);
   fetchResponseData->setURL(KURL(ParsedURLString, "http://www.response.com"));
   Response* response =
       Response::create(scope.getExecutionContext(), fetchResponseData);
@@ skipping 36 matching lines @@
   fetchResponseData = fetchResponseData->createOpaqueFilteredResponse();
   Response* response =
       Response::create(scope.getExecutionContext(), fetchResponseData);
   EXPECT_EQ(response->internalBodyBuffer(), buffer);
   checkResponseStream(scope.getScriptState(), response, false);
 }
 
 TEST(ServiceWorkerResponseTest, BodyStreamBufferCloneError) {
   V8TestingScope scope;
   BodyStreamBuffer* buffer = new BodyStreamBuffer(
-      scope.getScriptState(), createFetchDataConsumerHandleFromWebHandle(
-                                  createUnexpectedErrorDataConsumerHandle()));
+      scope.getScriptState(),
+      BytesConsumer::createErrored(BytesConsumer::Error()));
   FetchResponseData* fetchResponseData =
       FetchResponseData::createWithBuffer(buffer);
   fetchResponseData->setURL(KURL(ParsedURLString, "http://www.response.com"));
   Response* response =
       Response::create(scope.getExecutionContext(), fetchResponseData);
   TrackExceptionState exceptionState;
   Response* clonedResponse =
       response->clone(scope.getScriptState(), exceptionState);
   EXPECT_FALSE(exceptionState.hadException());
 
   BytesConsumerTestUtil::MockFetchDataLoaderClient* client1 =
       new BytesConsumerTestUtil::MockFetchDataLoaderClient();
   BytesConsumerTestUtil::MockFetchDataLoaderClient* client2 =
       new BytesConsumerTestUtil::MockFetchDataLoaderClient();
   EXPECT_CALL(*client1, didFetchDataLoadFailed());
   EXPECT_CALL(*client2, didFetchDataLoadFailed());
 
   response->internalBodyBuffer()->startLoading(
       FetchDataLoader::createLoaderAsString(), client1);
   clonedResponse->internalBodyBuffer()->startLoading(
       FetchDataLoader::createLoaderAsString(), client2);
   blink::testing::runPendingTasks();
 }
 
 }  // namespace
 }  // namespace blink