[Fetch API] Reflect spec changes of bodyUsed property

third_party/WebKit/Source/core/streams/ReadableStreamImpl.h

 // 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.
 
 #ifndef ReadableStreamImpl_h
 #define ReadableStreamImpl_h
 
 #include "bindings/core/v8/ExceptionState.h"
 #include "bindings/core/v8/ScriptPromise.h"
 #include "bindings/core/v8/ScriptPromiseResolver.h"
 #include "bindings/core/v8/ScriptState.h"
 #include "bindings/core/v8/ScriptValue.h"
+#include "bindings/core/v8/ToV8.h"
 #include "bindings/core/v8/V8ArrayBuffer.h"
 #include "bindings/core/v8/V8Binding.h"
 #include "bindings/core/v8/V8IteratorResultValue.h"
 #include "core/dom/DOMArrayBuffer.h"
 #include "core/dom/DOMArrayBufferView.h"
 #include "core/dom/DOMException.h"
 #include "core/streams/ReadableStream.h"
 #include "wtf/Deque.h"
 #include "wtf/RefPtr.h"
 #include "wtf/text/WTFString.h"
@@ skipping 161 matching lines @@
     if (!scriptState->contextIsValid())
         return false;
     ScriptState::Scope scope(scriptState);
     resolver->resolve(v8IteratorResult(scriptState, chunk));
     return enqueuePostAction();
 }
 
 template <typename ChunkTypeTraits>
 ScriptPromise ReadableStreamImpl<ChunkTypeTraits>::read(ScriptState* scriptState)
 {
+    if (stateInternal() == Closed)
+        return ScriptPromise::cast(scriptState, v8IteratorResultDone(scriptState));
+    if (stateInternal() == Errored)
+        return ScriptPromise::reject(scriptState, toV8(storedException(), scriptState->context()->Global(), scriptState->isolate()));
+
     ASSERT(stateInternal() == Readable);
     setIsDisturbed();
     if (m_queue.isEmpty()) {
         m_pendingReads.append(ScriptPromiseResolver::create(scriptState));
         ScriptPromise promise = m_pendingReads.last()->promise();
         readInternalPostAction();
         return promise;
     }
 
     auto pair = m_queue.takeFirst();
@@ skipping 16 matching lines @@
 
     setIsDisturbed();
     queue.swap(m_queue);
     m_totalQueueSize = 0;
     readInternalPostAction();
 }
 
 } // namespace blink
 
 #endif // ReadableStreamImpl_h