Index: third_party/WebKit/Source/modules/fetch/DataConsumerTee.cpp |
diff --git a/third_party/WebKit/Source/modules/fetch/DataConsumerTee.cpp b/third_party/WebKit/Source/modules/fetch/DataConsumerTee.cpp |
index a30dd8016c7c30a69b022ec2aa142202645ebffa..6ec7c80dc730cf39e55af507cdd1b19282a02cf9 100644 |
--- a/third_party/WebKit/Source/modules/fetch/DataConsumerTee.cpp |
+++ b/third_party/WebKit/Source/modules/fetch/DataConsumerTee.cpp |
@@ -317,9 +317,13 @@ public: |
return wrapUnique(new DestinationHandle(contextProxy)); |
} |
+ std::unique_ptr<Reader> obtainReader(Client* client) |
+ { |
+ return wrapUnique(new DestinationReader(m_contextProxy, client)); |
+ } |
+ |
private: |
DestinationHandle(PassRefPtr<DestinationContext::Proxy> contextProxy) : m_contextProxy(contextProxy) { } |
- DestinationReader* obtainReaderInternal(Client* client) { return new DestinationReader(m_contextProxy, client); } |
const char* debugName() const override { return "DestinationHandle"; } |
RefPtr<DestinationContext::Proxy> m_contextProxy; |
@@ -418,7 +422,7 @@ void DataConsumerTee::create(ExecutionContext* executionContext, std::unique_ptr |
void DataConsumerTee::create(ExecutionContext* executionContext, std::unique_ptr<FetchDataConsumerHandle> src, std::unique_ptr<FetchDataConsumerHandle>* dest1, std::unique_ptr<FetchDataConsumerHandle>* dest2) |
{ |
- RefPtr<BlobDataHandle> blobDataHandle = src->obtainReader(nullptr)->drainAsBlobDataHandle(FetchDataConsumerHandle::Reader::AllowBlobWithInvalidSize); |
+ RefPtr<BlobDataHandle> blobDataHandle = src->obtainFetchDataReader(nullptr)->drainAsBlobDataHandle(FetchDataConsumerHandle::Reader::AllowBlobWithInvalidSize); |
if (blobDataHandle) { |
*dest1 = FetchBlobDataConsumerHandle::create(executionContext, blobDataHandle); |
*dest2 = FetchBlobDataConsumerHandle::create(executionContext, blobDataHandle); |