[Streams] Remove SetReadableStreamDisturbed from ReadableStream.js

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

 // Copyright 2014 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/Request.h"
 
 #include "bindings/core/v8/Dictionary.h"
 #include "core/dom/Document.h"
 #include "core/dom/ExecutionContext.h"
 #include "core/fetch/FetchUtils.h"
@@ skipping 345 matching lines @@
     if (temporaryBody)
         r->m_request->setBuffer(temporaryBody);
 
     // "Set |r|'s MIME type to the result of extracting a MIME type from |r|'s
     // request's header list."
     r->m_request->setMIMEType(r->m_request->headerList()->extractMIMEType());
 
     // "If |input| is a Request object and |input|'s request's body is
     // non-null, run these substeps:"
     if (inputRequest && inputRequest->bodyBuffer()) {
-        // "Set |input|'s body to an empty byte stream."
-        inputRequest->m_request->setBuffer(new BodyStreamBuffer(scriptState, createFetchDataConsumerHandleFromWebHandle(createDoneDataConsumerHandle())));
-        // "Set |input|'s disturbed flag."
-        inputRequest->bodyBuffer()->setDisturbed();
+        // "Let |dummyStream| be an empty ReadableStream object."
+        auto dummyStream = new BodyStreamBuffer(scriptState, createFetchDataConsumerHandleFromWebHandle(createDoneDataConsumerHandle()));
+        // "Set |input|'s request's body to a new body whose stream is
+        // |dummyStream|."
+        inputRequest->m_request->setBuffer(dummyStream);
+        // "Let |reader| be the result of getting reader from |dummyStream|."
+        // "Read all bytes from |dummyStream| with |reader|."
+        inputRequest->bodyBuffer()->closeAndLockAndDisturb();
     }
 
     // "Return |r|."
     return r;
 }
 
 Request* Request::create(ScriptState* scriptState, const RequestInfo& input, const Dictionary& init, ExceptionState& exceptionState)
 {
     ASSERT(!input.isNull());
     if (input.isUSVString())
@@ skipping 283 matching lines @@
 }
 
 DEFINE_TRACE(Request)
 {
     Body::trace(visitor);
     visitor->trace(m_request);
     visitor->trace(m_headers);
 }
 
 } // namespace blink