Remove create[Done|UnexpectedError]DataConsumerHandle

third_party/WebKit/Source/modules/fetch/FetchManager.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/FetchManager.h"
 
 #include "bindings/core/v8/ExceptionState.h"
 #include "bindings/core/v8/ScriptPromiseResolver.h"
 #include "bindings/core/v8/ScriptState.h"
 #include "bindings/core/v8/V8ThrowException.h"
@@ skipping 215 matching lines @@
           // be called before didGetReadable() is called
           // when the data is ready. In that case,
           // didFinishLoading() doesn't clean up and call
           // notifyFinished(), so it is necessary to
           // explicitly finish the loader here.
           if (m_loader->m_didFinishLoading)
             m_loader->loadSucceeded();
           return;
         }
       }
-      m_updater->update(new BytesConsumerForDataConsumerHandle(
-          m_response->getExecutionContext(),
-          createFetchDataConsumerHandleFromWebHandle(
-              createUnexpectedErrorDataConsumerHandle())));
+      m_updater->update(
+          BytesConsumer::createErrored(BytesConsumer::Error(errorMessage)));
       m_loader->performNetworkError(errorMessage);
     }
 
     bool isFinished() const { return m_finished; }
 
     DEFINE_INLINE_TRACE() {
       visitor->trace(m_updater);
       visitor->trace(m_response);
       visitor->trace(m_loader);
     }
@@ skipping 162 matching lines @@
         RELEASE_NOTREACHED();
         break;
     }
   }
 
   FetchResponseData* responseData = nullptr;
   SRIBytesConsumer* sriConsumer = nullptr;
   if (m_request->integrity().isEmpty()) {
     responseData = FetchResponseData::createWithBuffer(new BodyStreamBuffer(
         scriptState,
-        createFetchDataConsumerHandleFromWebHandle(std::move(handle))));
+        new BytesConsumerForDataConsumerHandle(
+            scriptState->getExecutionContext(),
+            createFetchDataConsumerHandleFromWebHandle(std::move(handle)))));
   } else {
     sriConsumer = new SRIBytesConsumer();
     responseData = FetchResponseData::createWithBuffer(
         new BodyStreamBuffer(scriptState, sriConsumer));
   }
   responseData->setStatus(response.httpStatusCode());
   responseData->setStatusMessage(response.httpStatusText());
   for (auto& it : response.httpHeaderFields())
     responseData->headerList()->append(it.key, it.value);
   responseData->setURL(response.url());
@@ skipping 478 matching lines @@
   m_loaders.remove(loader);
   loader->dispose();
 }
 
 DEFINE_TRACE(FetchManager) {
   visitor->trace(m_loaders);
   ContextLifecycleObserver::trace(visitor);
 }
 
 }  // namespace blink