Add 'stream' to XMLHttpRequest response type.

Source/core/streams/ReadableStream.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 "config.h"
 #include "core/streams/ReadableStream.h"
 
 #include "bindings/core/v8/ExceptionState.h"
 #include "bindings/core/v8/ScriptFunction.h"
 #include "bindings/core/v8/ScriptPromiseResolver.h"
 #include "bindings/core/v8/V8Binding.h"
 #include "core/dom/DOMException.h"
 #include "core/dom/ExceptionCode.h"
 #include "core/dom/ExecutionContext.h"
 #include "core/streams/UnderlyingSource.h"
 
 namespace blink {
 
-class ReadableStream::OnStarted : public ScriptFunction {
-public:
-    OnStarted(v8::Isolate* isolate, ReadableStream* stream)
-        : ScriptFunction(isolate)
-        , m_stream(stream) { }
-    virtual ScriptValue call(ScriptValue value) OVERRIDE
-    {
-        m_stream->onStarted();
-        return value;
-    }
-
-private:
-    Persistent<ReadableStream> m_stream;
-};
-
-ReadableStream::ReadableStream(ScriptState* scriptState, UnderlyingSource* source, ExceptionState* exceptionState)
-    : ContextLifecycleObserver(scriptState->executionContext())
-    , m_source(source)
+ReadableStream::ReadableStream(ExecutionContext* executionContext, UnderlyingSource* source)
+    : m_source(source)
     , m_isStarted(false)
     , m_isDraining(false)
     , m_isPulling(false)
     , m_isSchedulingPull(false)
     , m_state(Waiting)
-    , m_wait(new WaitPromise(scriptState->executionContext(), this, WaitPromise::Ready))
-    , m_closed(new ClosedPromise(scriptState->executionContext(), this, ClosedPromise::Closed))
+    , m_wait(new WaitPromise(executionContext, this, WaitPromise::Ready))
+    , m_closed(new ClosedPromise(executionContext, this, ClosedPromise::Closed))
 {
     ScriptWrappable::init(this);
-
-    ScriptPromise promise = source->startSource(exceptionState);
-    // The underlying source calls |this->error| on failure.
-    promise.then(adoptPtr(new OnStarted(scriptState->isolate(), this)));
 }
 
 ReadableStream::~ReadableStream()
 {
 }
 
+String ReadableStream::stateString() const
+{
+    switch (m_state) {
+    case Readable:
+        return "readable";
+    case Waiting:
+        return "waiting";
+    case Closed:
+        return "closed";
+    case Errored:
+        return "errored";
+    }
+    ASSERT(false);
+}
+
 bool ReadableStream::enqueuePreliminaryCheck(size_t chunkSize)
 {
     if (m_state == Errored || m_state == Closed || m_isDraining)
         return false;
 
     // FIXME: Query strategy.
     return true;
 }
 
 bool ReadableStream::enqueuePostAction(size_t totalQueueSize)
@@ skipping 15 matching lines @@
 {
     if (m_state == Waiting) {
         m_wait->resolve(V8UndefinedType());
         m_closed->resolve(V8UndefinedType());
         m_state = Closed;
     } else if (m_state == Readable) {
         m_isDraining = true;
     }
 }
 
-void ReadableStream::readPreliminaryCheck(ExceptionState* exceptionState)
+void ReadableStream::readPreliminaryCheck(ExceptionState& exceptionState)
 {
     if (m_state == Waiting) {
-        exceptionState->throwTypeError("read is called while state is waiting");
+        exceptionState.throwTypeError("read is called while state is waiting");
         return;
     }
     if (m_state == Closed) {
-        exceptionState->throwTypeError("read is called while state is closed");
+        exceptionState.throwTypeError("read is called while state is closed");
         return;
     }
     if (m_state == Errored) {
-        exceptionState->throwDOMException(m_exception->code(), m_exception->message());
+        exceptionState.throwDOMException(m_exception->code(), m_exception->message());
         return;
     }
 }
 
 void ReadableStream::readPostAction()
 {
     ASSERT(m_state == Readable);
     if (isQueueEmpty()) {
         if (m_isDraining) {
             m_state = Closed;
@@ skipping 54 matching lines @@
 
     if (m_state == Waiting || m_state == Readable) {
         m_state = Errored;
         m_exception = exception;
         if (m_wait->state() == m_wait->Pending)
             m_wait->reject(m_exception);
         m_closed->reject(m_exception);
     }
 }
 
-void ReadableStream::onStarted()
+void ReadableStream::didSourceStart()
 {
     m_isStarted = true;
     if (m_isSchedulingPull)
         m_source->pullSource();
 }
 
 void ReadableStream::callOrSchedulePull()
 {
     if (m_isPulling)
         return;
     m_isPulling = true;
     if (m_isStarted)
         m_source->pullSource();
     else
         m_isSchedulingPull = true;
 }
 
 void ReadableStream::trace(Visitor* visitor)
 {
     visitor->trace(m_source);
     visitor->trace(m_wait);
     visitor->trace(m_closed);
     visitor->trace(m_exception);
 }
 
 } // namespace blink