Change BodyStreamBuffer to be FetchDataConsumerHandle-based and enable backpressure in Fetch API

Source/modules/fetch/FetchDataLoaderTest.cpp

 // Copyright 2015 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 "config.h"
 #include "modules/fetch/FetchDataLoader.h"
 
+#include "modules/fetch/DataConsumerHandleTestUtil.h"
+
 #include <gmock/gmock.h>
 #include <gtest/gtest.h>
 
 namespace blink {
 
 namespace {
 
 using ::testing::InSequence;
 using ::testing::Return;
 using ::testing::DoAll;
 using ::testing::StrictMock;
 using ::testing::_;
 using ::testing::SaveArg;
 using ::testing::SetArgPointee;
 using Checkpoint = StrictMock<::testing::MockFunction<void(int)>>;
+using MockFetchDataLoaderClient = DataConsumerHandleTestUtil::MockFetchDataLoaderClient;
 
 const WebDataConsumerHandle::Result kOk = WebDataConsumerHandle::Ok;
 const WebDataConsumerHandle::Result kUnexpectedError = WebDataConsumerHandle::UnexpectedError;
 const WebDataConsumerHandle::Result kDone = WebDataConsumerHandle::Done;
 const WebDataConsumerHandle::Flags kNone = WebDataConsumerHandle::FlagNone;
 
 class MockReader : public FetchDataConsumerHandle::Reader {
 public:
     static PassOwnPtr<StrictMock<MockReader>> create() { return adoptPtr(new StrictMock<MockReader>); }
 
@@ skipping 11 matching lines @@
     MOCK_METHOD0(destruct, void());
 };
 
 class MockHandle : public FetchDataConsumerHandle {
 public:
     static PassOwnPtr<StrictMock<MockHandle>> create() { return adoptPtr(new StrictMock<MockHandle>); }
 
     MOCK_METHOD1(obtainReaderInternal, Reader*(Client*));
 };
 
-class MockFetchDataLoaderClient : public GarbageCollectedFinalized<MockFetchDataLoaderClient>, public FetchDataLoader::Client {
-    USING_GARBAGE_COLLECTED_MIXIN(MockFetchDataLoaderClient);
-public:
-    static StrictMock<MockFetchDataLoaderClient>* create() { return new StrictMock<MockFetchDataLoaderClient>; }
-
-    DEFINE_INLINE_VIRTUAL_TRACE()
-    {
-        FetchDataLoader::Client::trace(visitor);
-    }
-
-    MOCK_METHOD1(didFetchDataLoadedBlobHandleMock, void(RefPtr<BlobDataHandle>));
-    MOCK_METHOD1(didFetchDataLoadedArrayBufferMock, void(RefPtr<DOMArrayBuffer>));
-    MOCK_METHOD1(didFetchDataLoadedString, void(const String&));
-    MOCK_METHOD0(didFetchDataLoadFailed, void());
-
-    // In mock methods we use RefPtr<> rather than PassRefPtr<>.
-    void didFetchDataLoadedArrayBuffer(PassRefPtr<DOMArrayBuffer> arrayBuffer) override
-    {
-        didFetchDataLoadedArrayBufferMock(arrayBuffer);
-    }
-    void didFetchDataLoadedBlobHandle(PassRefPtr<BlobDataHandle> blobDataHandle) override
-    {
-        didFetchDataLoadedBlobHandleMock(blobDataHandle);
-    }
-};
-
 const char kQuickBrownFox[] = "Quick brown fox";
 const size_t kQuickBrownFoxLength = 15;
 const size_t kQuickBrownFoxLengthWithTerminatingNull = 16;
 
 TEST(FetchDataLoaderTest, LoadAsBlob)
 {
     WebDataConsumerHandle::Client *client = nullptr;
     Checkpoint checkpoint;
 
     OwnPtr<MockHandle> handle = MockHandle::create();
@@ skipping 401 matching lines @@
     checkpoint.Call(1);
     fetchDataLoader->start(handle.get(), fetchDataLoaderClient);
     checkpoint.Call(2);
     fetchDataLoader->cancel();
     checkpoint.Call(3);
 }
 
 } // namespace
 
 } // namespace blink