[Fetch API] |(new Response(stream)).body| should return |stream|

third_party/WebKit/Source/core/streams/ReadableStreamOperations.cpp

 // Copyright 2015 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 "core/streams/ReadableStreamOperations.h"
 
 #include "bindings/core/v8/ExceptionState.h"
 #include "bindings/core/v8/ScriptState.h"
 #include "bindings/core/v8/ToV8.h"
 #include "bindings/core/v8/V8ScriptRunner.h"
@@ skipping 98 matching lines @@
 }
 
 ScriptPromise ReadableStreamOperations::defaultReaderRead(ScriptState* scriptState, ScriptValue reader)
 {
     ASSERT(isReadableStreamDefaultReader(scriptState, reader));
 
     v8::Local<v8::Value> args[] = { reader.v8Value() };
     return ScriptPromise::cast(scriptState, V8ScriptRunner::callExtraOrCrash(scriptState, "ReadableStreamDefaultReaderRead", args));
 }
 
+void ReadableStreamOperations::tee(ScriptState* scriptState, ScriptValue stream, ScriptValue* newStream1, ScriptValue* newStream2)
+{
+    DCHECK(isReadableStream(scriptState, stream));
+    DCHECK(!isLocked(scriptState, stream));
+
+    v8::Local<v8::Value> args[] = { stream.v8Value() };
+    ScriptValue result(scriptState, V8ScriptRunner::callExtraOrCrash(scriptState, "ReadableStreamTee", args));
+    DCHECK(result.v8Value()->IsArray());
+    v8::Local<v8::Array> branches = result.v8Value().As<v8::Array>();
+    DCHECK_EQ(2u, branches->Length());
+    *newStream1 = ScriptValue(scriptState, v8CallOrCrash(branches->Get(scriptState->context(), 0)));
+    *newStream2 = ScriptValue(scriptState, v8CallOrCrash(branches->Get(scriptState->context(), 1)));
+
+    DCHECK(isReadableStream(scriptState, *newStream1));
+    DCHECK(isReadableStream(scriptState, *newStream2));
+}
+
 } // namespace blink