Add Streams API support to XMLHttpRequest

Source/bindings/v8/custom/V8XMLHttpRequestCustom.cpp

 /*
  * Copyright (C) 2008, 2009, 2010 Google Inc. All rights reserved.
  *
  * Redistribution and use in source and binary forms, with or without
  * modification, are permitted provided that the following conditions are
  * met:
  *
  *     * Redistributions of source code must retain the above copyright
  * notice, this list of conditions and the following disclaimer.
  *     * Redistributions in binary form must reproduce the above
@@ skipping 18 matching lines @@
  */
 
 #include "config.h"
 #include "V8XMLHttpRequest.h"
 
 #include "V8ArrayBufferView.h"
 #include "V8Blob.h"
 #include "V8Document.h"
 #include "V8FormData.h"
 #include "V8HTMLDocument.h"
+#include "V8Stream.h"
 #include "bindings/v8/ExceptionState.h"
 #include "bindings/v8/V8Binding.h"
 #include "bindings/v8/V8Utilities.h"
 #include "bindings/v8/custom/V8ArrayBufferCustom.h"
 #include "core/dom/Document.h"
+#include "core/fileapi/Stream.h"
 #include "core/inspector/InspectorInstrumentation.h"
 #include "core/page/Frame.h"
 #include "core/workers/WorkerGlobalScope.h"
 #include "core/xml/XMLHttpRequest.h"
 #include "wtf/ArrayBuffer.h"
 
 namespace WebCore {
 
 void V8XMLHttpRequest::constructorCustom(const v8::FunctionCallbackInfo<v8::Value>& args)
 {
@@ skipping 49 matching lines @@
     case XMLHttpRequest::ResponseTypeBlob:
         {
             ExceptionState es(info.GetIsolate());
             Blob* blob = xmlHttpRequest->responseBlob(es);
             if (es.throwIfNeeded())
                 return;
             v8SetReturnValue(info, toV8Fast(blob, info, xmlHttpRequest));
             return;
         }
 
+    case XMLHttpRequest::ResponseTypeStream:
+        {
+            ExceptionState es(info.GetIsolate());
+            Stream* stream = xmlHttpRequest->responseStream(es);
+            if (es.throwIfNeeded())
+                return;
+            v8SetReturnValue(info, toV8Fast(stream, info, xmlHttpRequest));
+            return;
+        }
+
     case XMLHttpRequest::ResponseTypeArrayBuffer:
         {
             ExceptionState es(info.GetIsolate());
             ArrayBuffer* arrayBuffer = xmlHttpRequest->responseArrayBuffer(es);
             if (es.throwIfNeeded())
                 return;
             if (arrayBuffer && !arrayBuffer->hasDeallocationObserver()) {
                 arrayBuffer->setDeallocationObserver(V8ArrayBufferDeallocationObserver::instance());
                 v8::V8::AdjustAmountOfExternalAllocatedMemory(arrayBuffer->byteLength());
             }
@@ skipping 94 matching lines @@
             ASSERT(arrayBufferView);
             xmlHttpRequest->send(arrayBufferView, es);
         } else
             xmlHttpRequest->send(toWebCoreStringWithNullCheck(arg), es);
     }
 
     es.throwIfNeeded();
 }
 
 } // namespace WebCore