[Fetch API] Add streams predicates to BodyStreamBuffer

third_party/WebKit/Source/modules/fetch/Body.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/Body.h"
 
 #include "bindings/core/v8/ExceptionState.h"
 #include "bindings/core/v8/ScriptPromiseResolver.h"
 #include "bindings/core/v8/ScriptState.h"
 #include "bindings/core/v8/V8ArrayBuffer.h"
@@ skipping 252 matching lines @@
     if (bodyUsed() || isBodyLocked() || !bodyBuffer())
         return ScriptValue(scriptState, v8::Undefined(scriptState->isolate()));
     OwnPtr<FetchDataConsumerHandle> handle = bodyBuffer()->releaseHandle(scriptState->getExecutionContext());
     return ReadableStreamOperations::createReadableStream(scriptState,
         new UnderlyingSourceFromDataConsumerHandle(scriptState, handle.release()),
         ScriptValue(scriptState, v8::Undefined(scriptState->isolate())));
 }
 
 bool Body::bodyUsed()
 {
-    return body() && body()->isDisturbed();
+    return bodyBuffer() && bodyBuffer()->isStreamDisturbed();
 }
 
 bool Body::isBodyLocked()
 {
-    return body() && body()->isLocked();
+    return bodyBuffer() && bodyBuffer()->isStreamLocked();
 }
 
 bool Body::hasPendingActivity() const
 {
     if (getExecutionContext()->activeDOMObjectsAreStopped())
         return false;
     if (!bodyBuffer())
         return false;
     return bodyBuffer()->hasPendingActivity();
 }
 
 Body::Body(ExecutionContext* context)
     : ActiveScriptWrappable(this)
     , ActiveDOMObject(context)
 {
     suspendIfNeeded();
 }
 
 ScriptPromise Body::rejectInvalidConsumption(ScriptState* scriptState)
 {
     if (isBodyLocked() || bodyUsed())
         return ScriptPromise::reject(scriptState, V8ThrowException::createTypeError(scriptState->isolate(), "Already read"));
     return ScriptPromise();
 }
 
 } // namespace blink