Remove create[Done|UnexpectedError]DataConsumerHandle

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

 // Copyright 2016 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/BytesConsumer.h"
 
 #include "core/dom/ExecutionContext.h"
 #include "core/dom/TaskRunnerHelper.h"
 #include "modules/fetch/BlobBytesConsumer.h"
 #include "platform/blob/BlobData.h"
@@ skipping 280 matching lines @@
     m_destination2->clearChunks();
     m_destination1->notify();
     m_destination2->notify();
   }
 
   Member<BytesConsumer> m_src;
   Member<Destination> m_destination1;
   Member<Destination> m_destination2;
 };
 
+class ErroredBytesConsumer final : public BytesConsumer {
+ public:
+  explicit ErroredBytesConsumer(const Error& error) : m_error(error) {}
+
+  Result beginRead(const char** buffer, size_t* available) override {
+    *buffer = nullptr;
+    *available = 0;
+    return Result::Error;
+  }
+  Result endRead(size_t readSize) override {
+    NOTREACHED();
+    return Result::Error;
+  }
+  void setClient(BytesConsumer::Client*) override {}
+  void clearClient() override {}
+
+  void cancel() override {}
+  PublicState getPublicState() const override { return PublicState::Errored; }
+  Error getError() const override { return m_error; }
+  String debugName() const override { return "ErroredBytesConsumer"; }
+
+ private:
+  const Error m_error;
+};
+
+class ClosedBytesConsumer final : public BytesConsumer {
+ public:
+  Result beginRead(const char** buffer, size_t* available) override {
+    *buffer = nullptr;
+    *available = 0;
+    return Result::Done;
+  }
+  Result endRead(size_t readSize) override {
+    NOTREACHED();
+    return Result::Error;
+  }
+  void setClient(BytesConsumer::Client*) override {}
+  void clearClient() override {}
+
+  void cancel() override {}
+  PublicState getPublicState() const override { return PublicState::Closed; }
+  Error getError() const override {
+    NOTREACHED();
+    return Error();
+  }
+  String debugName() const override { return "ClosedBytesConsumer"; }
+};
+
 }  // namespace
 
 void BytesConsumer::tee(ExecutionContext* executionContext,
                         BytesConsumer* src,
                         BytesConsumer** dest1,
                         BytesConsumer** dest2) {
   RefPtr<BlobDataHandle> blobDataHandle =
       src->drainAsBlobDataHandle(BlobSizePolicy::AllowBlobWithInvalidSize);
   if (blobDataHandle) {
     // Register a client in order to be consistent.
     src->setClient(new NoopClient);
     *dest1 = new BlobBytesConsumer(executionContext, blobDataHandle);
     *dest2 = new BlobBytesConsumer(executionContext, blobDataHandle);
     return;
   }
 
   Tee* tee = new Tee(executionContext, src);
   *dest1 = tee->destination1();
   *dest2 = tee->destination2();
 }
 
+BytesConsumer* BytesConsumer::createErrored(const BytesConsumer::Error& error) {
+  return new ErroredBytesConsumer(error);
+}
+
+BytesConsumer* BytesConsumer::createClosed() {
+  return new ClosedBytesConsumer();
+}
+
 }  // namespace blink