Add methods for creating V8 extras-based ReadableStreams from C++

Source/core/testing/Internals.cpp

 /*
  * Copyright (C) 2012 Google Inc. All rights reserved.
  * Copyright (C) 2013 Apple 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:
  *
  * 1.  Redistributions of source code must retain the above copyright
  *     notice, this list of conditions and the following disclaimer.
@@ skipping 99 matching lines @@
 #include "core/loader/HistoryItem.h"
 #include "core/page/ChromeClient.h"
 #include "core/page/EventHandler.h"
 #include "core/page/FocusController.h"
 #include "core/page/NetworkStateNotifier.h"
 #include "core/page/Page.h"
 #include "core/page/PrintContext.h"
 #include "core/paint/DeprecatedPaintLayer.h"
 #include "core/plugins/testing/DictionaryPluginPlaceholder.h"
 #include "core/plugins/testing/DocumentFragmentPluginPlaceholder.h"
+#include "core/streams/ReadableStream2.h"
 #include "core/testing/DictionaryTest.h"
 #include "core/testing/GCObservation.h"
 #include "core/testing/InternalRuntimeFlags.h"
 #include "core/testing/InternalSettings.h"
 #include "core/testing/LayerRect.h"
 #include "core/testing/LayerRectList.h"
 #include "core/testing/PluginPlaceholderOptions.h"
 #include "core/testing/PrivateScriptTest.h"
 #include "core/testing/TypeConversions.h"
 #include "core/testing/UnionTypesTest.h"
@@ skipping 55 matching lines @@
 
 static SpellCheckRequester* spellCheckRequester(Document* document)
 {
     if (!document || !document->frame())
         return 0;
     return &document->frame()->spellChecker().spellCheckRequester();
 }
 
 const char* Internals::internalsId = "internals";
 
-Internals* Internals::create(Document* document)
+Internals* Internals::create(ScriptState* scriptState)
 {
-    return new Internals(document);
+    return new Internals(scriptState);
 }
 
 Internals::~Internals()
 {
 }
 
 void Internals::resetToConsistentState(Page* page)
 {
     ASSERT(page);
 
     page->setDeviceScaleFactor(1);
     page->setIsCursorVisible(true);
     page->setPageScaleFactor(1, IntPoint(0, 0));
     overrideUserPreferredLanguages(Vector<AtomicString>());
     if (!page->deprecatedLocalMainFrame()->spellChecker().isContinuousSpellCheckingEnabled())
         page->deprecatedLocalMainFrame()->spellChecker().toggleContinuousSpellChecking();
     if (page->deprecatedLocalMainFrame()->editor().isOverwriteModeEnabled())
         page->deprecatedLocalMainFrame()->editor().toggleOverwriteModeEnabled();
 
     if (ScrollingCoordinator* scrollingCoordinator = page->scrollingCoordinator())
         scrollingCoordinator->reset();
 
     page->deprecatedLocalMainFrame()->view()->clear();
 }
 
-Internals::Internals(Document* document)
-    : ContextLifecycleObserver(document)
+namespace {
+
+class TestUnderlyingSource : public UnderlyingSourceBase {
+public:
+    ScriptPromise start(ScriptState* scriptState) override
+    {
+        controller().enqueue("a");
+        controller().enqueue("b");
+        controller().close();
+        return UnderlyingSourceBase::start(scriptState);
+    };
+};
+
+} // namespace
+
+Internals::Internals(ScriptState* scriptState)
+    : ContextLifecycleObserver(scriptState->executionContext())
     , m_runtimeFlags(InternalRuntimeFlags::create())
+    , m_readableStream(new ReadableStream2(scriptState, new TestUnderlyingSource(),
+        ReadableStream2::createCountQueuingStrategy(scriptState, 1024.0)))
 {
 }
 
 Document* Internals::contextDocument() const
 {
     return toDocument(executionContext());
 }
 
 LocalFrame* Internals::frame() const
 {
@@ skipping 2127 matching lines @@
 }
 
 ClientRectList* Internals::focusRingRects(Element* element)
 {
     Vector<LayoutRect> rects;
     if (element && element->layoutObject())
         element->layoutObject()->addFocusRingRects(rects, LayoutPoint());
     return ClientRectList::create(rects);
 }
 
+ScriptValue Internals::readableStream()
+{
+    return m_readableStream->scriptValue();
+}
+
 } // namespace blink