[Fetch API] Introduce BytesConsumer

third_party/WebKit/Source/modules/fetch/BytesConsumerForDataConsumerHandle.h

Index: third_party/WebKit/Source/modules/fetch/BytesConsumerForDataConsumerHandle.h
diff --git a/third_party/WebKit/Source/modules/fetch/BytesConsumerForDataConsumerHandle.h b/third_party/WebKit/Source/modules/fetch/BytesConsumerForDataConsumerHandle.h
new file mode 100644
index 0000000000000000000000000000000000000000..bc6dc8d76ae0f7793129cf188f2e8030afe60be2
--- /dev/null
+++ b/third_party/WebKit/Source/modules/fetch/BytesConsumerForDataConsumerHandle.h
@@ -0,0 +1,56 @@
+// 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.
+
+#ifndef BytesConsumerForDataConsumerHandle_h
+#define BytesConsumerForDataConsumerHandle_h
+
+#include "modules/ModulesExport.h"
+#include "modules/fetch/BytesConsumer.h"
+#include "modules/fetch/FetchFormDataConsumerHandle.h"
+#include "platform/heap/Handle.h"
+#include "public/platform/WebDataConsumerHandle.h"
+#include "wtf/OwnPtr.h"
+#include "wtf/PassOwnPtr.h"
+#include "wtf/PassRefPtr.h"
+#include "wtf/text/WTFString.h"
+
+namespace blink {
+
+class MODULES_EXPORT BytesConsumerForDataConsumerHandle : public BytesConsumer, public WebDataConsumerHandle::Client {
+    EAGERLY_FINALIZE();
+    DECLARE_EAGER_FINALIZATION_OPERATOR_NEW();
+public:
+    explicit BytesConsumerForDataConsumerHandle(PassOwnPtr<FetchDataConsumerHandle>);
+    ~BytesConsumerForDataConsumerHandle() override;
+
+    Result read(char* buffer, size_t /* size */, size_t* readSize) override;
+    Result beginRead(const char** buffer, size_t* available) override;
+    PassRefPtr<BlobDataHandle> drainAsBlobDataHandle(BlobSizePolicy) override;
+    PassRefPtr<EncodedFormData> drainAsFormData() override;
+    Result endRead(size_t readSize) override;
+    void setClient(BytesConsumer::Client*) override;
+    void clearClient() override;
+
+    void cancel() override;
+    Error getError() const override { return m_error; }
+    String debugName() const override { return "BytesConsumerForDataConsumerHandle"; }
+
+    // WebDataConsumerHandle::Client
+    void didGetReadable() override;
+
+    DECLARE_TRACE();
+
+private:
+    void close();
+    void error();
+
+    OwnPtr<FetchDataConsumerHandle::Reader> m_reader;
+    Member<BytesConsumer::Client> m_client;
+    State m_state = State::Waiting;
+    Error m_error;
+};
+
+} // namespace blink
+
+#endif // BytesConsumerForDataConsumerHandle_h