| Index: third_party/WebKit/Source/modules/fetch/BodyStreamBuffer.cpp
|
| diff --git a/third_party/WebKit/Source/modules/fetch/BodyStreamBuffer.cpp b/third_party/WebKit/Source/modules/fetch/BodyStreamBuffer.cpp
|
| index 27d7194e227dec12d69ffb4a46d1f4629f2ecc9c..0da568020a8a300f9977abc4ffe4fa9681e78975 100644
|
| --- a/third_party/WebKit/Source/modules/fetch/BodyStreamBuffer.cpp
|
| +++ b/third_party/WebKit/Source/modules/fetch/BodyStreamBuffer.cpp
|
| @@ -14,6 +14,7 @@
|
| #include "core/streams/ReadableStreamOperations.h"
|
| #include "core/workers/WorkerGlobalScope.h"
|
| #include "modules/fetch/Body.h"
|
| +#include "modules/fetch/BytesConsumerForDataConsumerHandle.h"
|
| #include "modules/fetch/DataConsumerHandleUtil.h"
|
| #include "modules/fetch/DataConsumerTee.h"
|
| #include "modules/fetch/ReadableStreamDataConsumerHandle.h"
|
| @@ -205,7 +206,7 @@ void BodyStreamBuffer::startLoading(FetchDataLoader* loader, FetchDataLoader::Cl
|
| ASSERT(m_scriptState->contextIsValid());
|
| std::unique_ptr<FetchDataConsumerHandle> handle = releaseHandle();
|
| m_loader = loader;
|
| - loader->start(handle.get(), new LoaderClient(m_scriptState->getExecutionContext(), this, client));
|
| + loader->start(new BytesConsumerForDataConsumerHandle(std::move(handle)), new LoaderClient(m_scriptState->getExecutionContext(), this, client));
|
| }
|
|
|
| void BodyStreamBuffer::tee(BodyStreamBuffer** branch1, BodyStreamBuffer** branch2)
|
|
|