Use v8::MicrotasksScope internally in V8RecursionScope.

third_party/WebKit/Source/core/streams/ReadableStreamTest.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 "core/streams/ReadableStream.h"
 
 #include "bindings/core/v8/ExceptionState.h"
 #include "bindings/core/v8/ScriptPromiseResolver.h"
 #include "bindings/core/v8/ScriptState.h"
 #include "bindings/core/v8/V8Binding.h"
@@ skipping 286 matching lines @@
     EXPECT_TRUE(stream->enqueue("bye"));
     stream->close();
     EXPECT_FALSE(stream->enqueue("should be ignored"));
 
     EXPECT_EQ(ReadableStream::Readable, stream->stateInternal());
     EXPECT_FALSE(stream->isPulling());
     EXPECT_TRUE(stream->isDraining());
 
     stream->read(getScriptState());
 
-    isolate()->RunMicrotasks();
+    v8::MicrotasksScope::PerformCheckpoint(isolate());
 
     EXPECT_EQ(ReadableStream::Readable, stream->stateInternal());
     EXPECT_FALSE(stream->isPulling());
     EXPECT_TRUE(stream->isDraining());
 
     stream->read(getScriptState());
 
     EXPECT_EQ(ReadableStream::Closed, stream->stateInternal());
     EXPECT_FALSE(stream->isPulling());
     EXPECT_TRUE(stream->isDraining());
@@ skipping 10 matching lines @@
 
     EXPECT_FALSE(stream->isDisturbed());
     ScriptPromise promise = stream->cancel(getScriptState(), ScriptValue());
     EXPECT_TRUE(stream->isDisturbed());
     EXPECT_EQ(ReadableStream::Closed, stream->stateInternal());
 
     promise.then(createCaptor(&onFulfilled), createCaptor(&onRejected));
     EXPECT_TRUE(onFulfilled.isNull());
     EXPECT_TRUE(onRejected.isNull());
 
-    isolate()->RunMicrotasks();
+    v8::MicrotasksScope::PerformCheckpoint(isolate());
     EXPECT_EQ("undefined", onFulfilled);
     EXPECT_TRUE(onRejected.isNull());
 }
 
 TEST_F(ReadableStreamTest, CancelWhenErrored)
 {
     ScriptState::Scope scope(getScriptState());
     ExceptionState exceptionState(ExceptionState::ConstructionContext, "property", "interface", getScriptState()->context()->Global(), isolate());
     StringStream* stream = construct();
     String onFulfilled, onRejected;
     stream->error(DOMException::create(NotFoundError, "error"));
     EXPECT_EQ(ReadableStream::Errored, stream->stateInternal());
 
     EXPECT_FALSE(stream->isDisturbed());
     ScriptPromise promise = stream->cancel(getScriptState(), ScriptValue());
     EXPECT_TRUE(stream->isDisturbed());
     EXPECT_EQ(ReadableStream::Errored, stream->stateInternal());
 
     promise.then(createCaptor(&onFulfilled), createCaptor(&onRejected));
     EXPECT_TRUE(onFulfilled.isNull());
     EXPECT_TRUE(onRejected.isNull());
 
-    isolate()->RunMicrotasks();
+    v8::MicrotasksScope::PerformCheckpoint(isolate());
     EXPECT_TRUE(onFulfilled.isNull());
     EXPECT_EQ("NotFoundError: error", onRejected);
 }
 
 TEST_F(ReadableStreamTest, CancelWhenReadable)
 {
     ScriptState::Scope scope(getScriptState());
     ExceptionState exceptionState(ExceptionState::ConstructionContext, "property", "interface", getScriptState()->context()->Global(), isolate());
     StringStream* stream = construct();
     String onFulfilled, onRejected;
@@ skipping 13 matching lines @@
     ScriptPromise cancelResult = stream->cancel(getScriptState(), reason);
     EXPECT_TRUE(stream->isDisturbed());
     cancelResult.then(createCaptor(&onCancelFulfilled), createCaptor(&onCancelRejected));
 
     EXPECT_NE(promise, cancelResult);
     EXPECT_EQ(ReadableStream::Closed, stream->stateInternal());
 
     EXPECT_TRUE(onCancelFulfilled.isNull());
     EXPECT_TRUE(onCancelRejected.isNull());
 
-    isolate()->RunMicrotasks();
+    v8::MicrotasksScope::PerformCheckpoint(isolate());
     EXPECT_EQ("undefined", onCancelFulfilled);
     EXPECT_TRUE(onCancelRejected.isNull());
 }
 
 TEST_F(ReadableStreamTest, CancelWhenLocked)
 {
     ScriptState::Scope scope(getScriptState());
     ExceptionState exceptionState(ExceptionState::ConstructionContext, "property", "interface", getScriptState()->context()->Global(), isolate());
     String onFulfilled, onRejected;
     StringStream* stream = construct();
     ReadableStreamReader* reader = stream->getReader(getScriptState()->getExecutionContext(), exceptionState);
 
     EXPECT_TRUE(reader->isActive());
     EXPECT_FALSE(exceptionState.hadException());
     EXPECT_EQ(ReadableStream::Readable, stream->stateInternal());
 
     EXPECT_FALSE(stream->isDisturbed());
     stream->cancel(getScriptState(), ScriptValue(getScriptState(), v8::Undefined(isolate()))).then(createCaptor(&onFulfilled), createCaptor(&onRejected));
     EXPECT_FALSE(stream->isDisturbed());
 
     EXPECT_TRUE(onFulfilled.isNull());
     EXPECT_TRUE(onRejected.isNull());
 
-    isolate()->RunMicrotasks();
+    v8::MicrotasksScope::PerformCheckpoint(isolate());
 
     EXPECT_TRUE(onFulfilled.isNull());
     EXPECT_EQ("TypeError: this stream is locked to a ReadableStreamReader", onRejected);
     EXPECT_TRUE(reader->isActive());
     EXPECT_EQ(ReadableStream::Readable, stream->stateInternal());
 }
 
 TEST_F(ReadableStreamTest, ReadableArrayBufferStreamCompileTest)
 {
     ScriptState::Scope scope(getScriptState());
@@ skipping 126 matching lines @@
     ASSERT_TRUE(reader);
     EXPECT_FALSE(exceptionState.hadException());
 
     String onFulfilled, onRejected;
     reader->closed(getScriptState()).then(createCaptor(&onFulfilled), createCaptor(&onRejected));
 
     EXPECT_TRUE(reader->isActive());
     EXPECT_TRUE(onFulfilled.isNull());
     EXPECT_TRUE(onRejected.isNull());
 
-    isolate()->RunMicrotasks();
+    v8::MicrotasksScope::PerformCheckpoint(isolate());
     EXPECT_EQ("undefined", onFulfilled);
     EXPECT_TRUE(onRejected.isNull());
 }
 
 TEST_F(ReadableStreamTest, GetErroredReader)
 {
     ScriptState::Scope scope(getScriptState());
     ExceptionState exceptionState(ExceptionState::ConstructionContext, "property", "interface", getScriptState()->context()->Global(), isolate());
     StringStream* stream = construct();
     stream->error(DOMException::create(SyntaxError, "some error"));
     ReadableStreamReader* reader = stream->getReader(getScriptState()->getExecutionContext(), exceptionState);
 
     ASSERT_TRUE(reader);
     EXPECT_FALSE(exceptionState.hadException());
 
     String onFulfilled, onRejected;
     reader->closed(getScriptState()).then(createCaptor(&onFulfilled), createCaptor(&onRejected));
 
     EXPECT_TRUE(reader->isActive());
     EXPECT_TRUE(onFulfilled.isNull());
     EXPECT_TRUE(onRejected.isNull());
 
-    isolate()->RunMicrotasks();
+    v8::MicrotasksScope::PerformCheckpoint(isolate());
     EXPECT_TRUE(onFulfilled.isNull());
     EXPECT_EQ("SyntaxError: some error", onRejected);
 }
 
 TEST_F(ReadableStreamTest, StrictStrategy)
 {
     ScriptState::Scope scope(getScriptState());
     ExceptionState exceptionState(ExceptionState::ConstructionContext, "property", "interface", getScriptState()->context()->Global(), isolate());
     Checkpoint checkpoint;
     {
@@ skipping 44 matching lines @@
     reader->read(getScriptState());
     EXPECT_FALSE(stream->isPulling());
     checkpoint.Call(9);
     reader->read(getScriptState());
     EXPECT_TRUE(stream->isPulling());
 
     stream->error(DOMException::create(AbortError, "done"));
 }
 
 } // namespace blink