| Index: third_party/WebKit/Source/core/streams/ReadableStreamTest.cpp
|
| diff --git a/third_party/WebKit/Source/core/streams/ReadableStreamTest.cpp b/third_party/WebKit/Source/core/streams/ReadableStreamTest.cpp
|
| index 031ecddbdeb8e548d64d220adb58aaffbe9e5b11..8ee42c8392f5c761fb0d6482a7e9dd60b3ac25ae 100644
|
| --- a/third_party/WebKit/Source/core/streams/ReadableStreamTest.cpp
|
| +++ b/third_party/WebKit/Source/core/streams/ReadableStreamTest.cpp
|
| @@ -51,7 +51,7 @@ private:
|
| ScriptValue call(ScriptValue value) override
|
| {
|
| ASSERT(!value.isEmpty());
|
| - *m_value = toCoreString(value.v8Value()->ToString(scriptState()->context()).ToLocalChecked());
|
| + *m_value = toCoreString(value.v8Value()->ToString(getScriptState()->context()).ToLocalChecked());
|
| return value;
|
| }
|
|
|
| @@ -114,12 +114,12 @@ public:
|
| {
|
| }
|
|
|
| - ScriptState* scriptState() { return ScriptState::forMainWorld(m_page->document().frame()); }
|
| - v8::Isolate* isolate() { return scriptState()->isolate(); }
|
| + ScriptState* getScriptState() { return ScriptState::forMainWorld(m_page->document().frame()); }
|
| + v8::Isolate* isolate() { return getScriptState()->isolate(); }
|
|
|
| v8::Local<v8::Function> createCaptor(String* value)
|
| {
|
| - return StringCapturingFunction::createFunction(scriptState(), value);
|
| + return StringCapturingFunction::createFunction(getScriptState(), value);
|
| }
|
|
|
| StringStream* construct(MockStrategy* strategy)
|
| @@ -159,8 +159,8 @@ public:
|
|
|
| TEST_F(ReadableStreamTest, Start)
|
| {
|
| - ScriptState::Scope scope(scriptState());
|
| - ExceptionState exceptionState(ExceptionState::ConstructionContext, "property", "interface", scriptState()->context()->Global(), isolate());
|
| + ScriptState::Scope scope(getScriptState());
|
| + ExceptionState exceptionState(ExceptionState::ConstructionContext, "property", "interface", getScriptState()->context()->Global(), isolate());
|
| Checkpoint checkpoint;
|
| {
|
| InSequence s;
|
| @@ -193,8 +193,8 @@ TEST_F(ReadableStreamTest, Start)
|
|
|
| TEST_F(ReadableStreamTest, StartFail)
|
| {
|
| - ScriptState::Scope scope(scriptState());
|
| - ExceptionState exceptionState(ExceptionState::ConstructionContext, "property", "interface", scriptState()->context()->Global(), isolate());
|
| + ScriptState::Scope scope(getScriptState());
|
| + ExceptionState exceptionState(ExceptionState::ConstructionContext, "property", "interface", getScriptState()->context()->Global(), isolate());
|
| StringStream* stream = new StringStream(m_underlyingSource);
|
| EXPECT_FALSE(exceptionState.hadException());
|
| EXPECT_FALSE(stream->isStarted());
|
| @@ -212,8 +212,8 @@ TEST_F(ReadableStreamTest, StartFail)
|
|
|
| TEST_F(ReadableStreamTest, ErrorAndEnqueue)
|
| {
|
| - ScriptState::Scope scope(scriptState());
|
| - ExceptionState exceptionState(ExceptionState::ConstructionContext, "property", "interface", scriptState()->context()->Global(), isolate());
|
| + ScriptState::Scope scope(getScriptState());
|
| + ExceptionState exceptionState(ExceptionState::ConstructionContext, "property", "interface", getScriptState()->context()->Global(), isolate());
|
| StringStream* stream = construct();
|
|
|
| stream->error(DOMException::create(NotFoundError, "error"));
|
| @@ -226,8 +226,8 @@ TEST_F(ReadableStreamTest, ErrorAndEnqueue)
|
|
|
| TEST_F(ReadableStreamTest, CloseAndEnqueue)
|
| {
|
| - ScriptState::Scope scope(scriptState());
|
| - ExceptionState exceptionState(ExceptionState::ConstructionContext, "property", "interface", scriptState()->context()->Global(), isolate());
|
| + ScriptState::Scope scope(getScriptState());
|
| + ExceptionState exceptionState(ExceptionState::ConstructionContext, "property", "interface", getScriptState()->context()->Global(), isolate());
|
| StringStream* stream = construct();
|
|
|
| stream->close();
|
| @@ -240,8 +240,8 @@ TEST_F(ReadableStreamTest, CloseAndEnqueue)
|
|
|
| TEST_F(ReadableStreamTest, CloseWhenErrored)
|
| {
|
| - ScriptState::Scope scope(scriptState());
|
| - ExceptionState exceptionState(ExceptionState::ConstructionContext, "property", "interface", scriptState()->context()->Global(), isolate());
|
| + ScriptState::Scope scope(getScriptState());
|
| + ExceptionState exceptionState(ExceptionState::ConstructionContext, "property", "interface", getScriptState()->context()->Global(), isolate());
|
| StringStream* stream = construct();
|
| EXPECT_EQ(ReadableStream::Readable, stream->stateInternal());
|
|
|
| @@ -253,8 +253,8 @@ TEST_F(ReadableStreamTest, CloseWhenErrored)
|
|
|
| TEST_F(ReadableStreamTest, ReadQueue)
|
| {
|
| - ScriptState::Scope scope(scriptState());
|
| - ExceptionState exceptionState(ExceptionState::ConstructionContext, "property", "interface", scriptState()->context()->Global(), isolate());
|
| + ScriptState::Scope scope(getScriptState());
|
| + ExceptionState exceptionState(ExceptionState::ConstructionContext, "property", "interface", getScriptState()->context()->Global(), isolate());
|
| StringStream* stream = construct();
|
| Checkpoint checkpoint;
|
|
|
| @@ -289,8 +289,8 @@ TEST_F(ReadableStreamTest, ReadQueue)
|
|
|
| TEST_F(ReadableStreamTest, CloseWhenReadable)
|
| {
|
| - ScriptState::Scope scope(scriptState());
|
| - ExceptionState exceptionState(ExceptionState::ConstructionContext, "property", "interface", scriptState()->context()->Global(), isolate());
|
| + ScriptState::Scope scope(getScriptState());
|
| + ExceptionState exceptionState(ExceptionState::ConstructionContext, "property", "interface", getScriptState()->context()->Global(), isolate());
|
| StringStream* stream = construct();
|
|
|
| EXPECT_TRUE(stream->enqueue("hello"));
|
| @@ -302,7 +302,7 @@ TEST_F(ReadableStreamTest, CloseWhenReadable)
|
| EXPECT_FALSE(stream->isPulling());
|
| EXPECT_TRUE(stream->isDraining());
|
|
|
| - stream->read(scriptState());
|
| + stream->read(getScriptState());
|
|
|
| v8::MicrotasksScope::PerformCheckpoint(isolate());
|
|
|
| @@ -310,7 +310,7 @@ TEST_F(ReadableStreamTest, CloseWhenReadable)
|
| EXPECT_FALSE(stream->isPulling());
|
| EXPECT_TRUE(stream->isDraining());
|
|
|
| - stream->read(scriptState());
|
| + stream->read(getScriptState());
|
|
|
| EXPECT_EQ(ReadableStream::Closed, stream->stateInternal());
|
| EXPECT_FALSE(stream->isPulling());
|
| @@ -319,15 +319,15 @@ TEST_F(ReadableStreamTest, CloseWhenReadable)
|
|
|
| TEST_F(ReadableStreamTest, CancelWhenClosed)
|
| {
|
| - ScriptState::Scope scope(scriptState());
|
| - ExceptionState exceptionState(ExceptionState::ConstructionContext, "property", "interface", scriptState()->context()->Global(), isolate());
|
| + ScriptState::Scope scope(getScriptState());
|
| + ExceptionState exceptionState(ExceptionState::ConstructionContext, "property", "interface", getScriptState()->context()->Global(), isolate());
|
| StringStream* stream = construct();
|
| String onFulfilled, onRejected;
|
| stream->close();
|
| EXPECT_EQ(ReadableStream::Closed, stream->stateInternal());
|
|
|
| EXPECT_FALSE(stream->isDisturbed());
|
| - ScriptPromise promise = stream->cancel(scriptState(), ScriptValue());
|
| + ScriptPromise promise = stream->cancel(getScriptState(), ScriptValue());
|
| EXPECT_TRUE(stream->isDisturbed());
|
| EXPECT_EQ(ReadableStream::Closed, stream->stateInternal());
|
|
|
| @@ -342,15 +342,15 @@ TEST_F(ReadableStreamTest, CancelWhenClosed)
|
|
|
| TEST_F(ReadableStreamTest, CancelWhenErrored)
|
| {
|
| - ScriptState::Scope scope(scriptState());
|
| - ExceptionState exceptionState(ExceptionState::ConstructionContext, "property", "interface", scriptState()->context()->Global(), isolate());
|
| + 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(scriptState(), ScriptValue());
|
| + ScriptPromise promise = stream->cancel(getScriptState(), ScriptValue());
|
| EXPECT_TRUE(stream->isDisturbed());
|
| EXPECT_EQ(ReadableStream::Errored, stream->stateInternal());
|
|
|
| @@ -365,24 +365,24 @@ TEST_F(ReadableStreamTest, CancelWhenErrored)
|
|
|
| TEST_F(ReadableStreamTest, CancelWhenReadable)
|
| {
|
| - ScriptState::Scope scope(scriptState());
|
| - ExceptionState exceptionState(ExceptionState::ConstructionContext, "property", "interface", scriptState()->context()->Global(), isolate());
|
| + ScriptState::Scope scope(getScriptState());
|
| + ExceptionState exceptionState(ExceptionState::ConstructionContext, "property", "interface", getScriptState()->context()->Global(), isolate());
|
| StringStream* stream = construct();
|
| String onFulfilled, onRejected;
|
| String onCancelFulfilled, onCancelRejected;
|
| - ScriptValue reason(scriptState(), v8String(scriptState()->isolate(), "reason"));
|
| - ScriptPromise promise = ScriptPromise::cast(scriptState(), v8String(scriptState()->isolate(), "hello"));
|
| + ScriptValue reason(getScriptState(), v8String(getScriptState()->isolate(), "reason"));
|
| + ScriptPromise promise = ScriptPromise::cast(getScriptState(), v8String(getScriptState()->isolate(), "hello"));
|
|
|
| {
|
| InSequence s;
|
| - EXPECT_CALL(*m_underlyingSource, cancelSource(scriptState(), reason)).WillOnce(ReturnPointee(&promise));
|
| + EXPECT_CALL(*m_underlyingSource, cancelSource(getScriptState(), reason)).WillOnce(ReturnPointee(&promise));
|
| }
|
|
|
| stream->enqueue("hello");
|
| EXPECT_EQ(ReadableStream::Readable, stream->stateInternal());
|
|
|
| EXPECT_FALSE(stream->isDisturbed());
|
| - ScriptPromise cancelResult = stream->cancel(scriptState(), reason);
|
| + ScriptPromise cancelResult = stream->cancel(getScriptState(), reason);
|
| EXPECT_TRUE(stream->isDisturbed());
|
| cancelResult.then(createCaptor(&onCancelFulfilled), createCaptor(&onCancelRejected));
|
|
|
| @@ -399,18 +399,18 @@ TEST_F(ReadableStreamTest, CancelWhenReadable)
|
|
|
| TEST_F(ReadableStreamTest, CancelWhenLocked)
|
| {
|
| - ScriptState::Scope scope(scriptState());
|
| - ExceptionState exceptionState(ExceptionState::ConstructionContext, "property", "interface", scriptState()->context()->Global(), isolate());
|
| + ScriptState::Scope scope(getScriptState());
|
| + ExceptionState exceptionState(ExceptionState::ConstructionContext, "property", "interface", getScriptState()->context()->Global(), isolate());
|
| String onFulfilled, onRejected;
|
| StringStream* stream = construct();
|
| - ReadableStreamReader* reader = stream->getReader(scriptState()->executionContext(), exceptionState);
|
| + 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(scriptState(), ScriptValue(scriptState(), v8::Undefined(isolate()))).then(createCaptor(&onFulfilled), createCaptor(&onRejected));
|
| + stream->cancel(getScriptState(), ScriptValue(getScriptState(), v8::Undefined(isolate()))).then(createCaptor(&onFulfilled), createCaptor(&onRejected));
|
| EXPECT_FALSE(stream->isDisturbed());
|
|
|
| EXPECT_TRUE(onFulfilled.isNull());
|
| @@ -426,8 +426,8 @@ TEST_F(ReadableStreamTest, CancelWhenLocked)
|
|
|
| TEST_F(ReadableStreamTest, ReadableArrayBufferStreamCompileTest)
|
| {
|
| - ScriptState::Scope scope(scriptState());
|
| - ExceptionState exceptionState(ExceptionState::ConstructionContext, "property", "interface", scriptState()->context()->Global(), isolate());
|
| + ScriptState::Scope scope(getScriptState());
|
| + ExceptionState exceptionState(ExceptionState::ConstructionContext, "property", "interface", getScriptState()->context()->Global(), isolate());
|
| // This test tests if ReadableStreamImpl<DOMArrayBuffer> can be
|
| // instantiated.
|
| new ReadableStreamImpl<ReadableStreamChunkTypeTraits<DOMArrayBuffer>>(m_underlyingSource);
|
| @@ -435,8 +435,8 @@ TEST_F(ReadableStreamTest, ReadableArrayBufferStreamCompileTest)
|
|
|
| TEST_F(ReadableStreamTest, ReadableArrayBufferViewStreamCompileTest)
|
| {
|
| - ScriptState::Scope scope(scriptState());
|
| - ExceptionState exceptionState(ExceptionState::ConstructionContext, "property", "interface", scriptState()->context()->Global(), isolate());
|
| + ScriptState::Scope scope(getScriptState());
|
| + ExceptionState exceptionState(ExceptionState::ConstructionContext, "property", "interface", getScriptState()->context()->Global(), isolate());
|
| // This test tests if ReadableStreamImpl<DOMArrayBufferVIew> can be
|
| // instantiated.
|
| new ReadableStreamImpl<ReadableStreamChunkTypeTraits<DOMArrayBufferView>>(m_underlyingSource);
|
| @@ -444,8 +444,8 @@ TEST_F(ReadableStreamTest, ReadableArrayBufferViewStreamCompileTest)
|
|
|
| TEST_F(ReadableStreamTest, BackpressureOnEnqueueing)
|
| {
|
| - ScriptState::Scope scope(scriptState());
|
| - ExceptionState exceptionState(ExceptionState::ConstructionContext, "property", "interface", scriptState()->context()->Global(), isolate());
|
| + ScriptState::Scope scope(getScriptState());
|
| + ExceptionState exceptionState(ExceptionState::ConstructionContext, "property", "interface", getScriptState()->context()->Global(), isolate());
|
| auto strategy = MockStrategy::create();
|
| Checkpoint checkpoint;
|
|
|
| @@ -478,8 +478,8 @@ TEST_F(ReadableStreamTest, BackpressureOnEnqueueing)
|
|
|
| TEST_F(ReadableStreamTest, BackpressureOnReading)
|
| {
|
| - ScriptState::Scope scope(scriptState());
|
| - ExceptionState exceptionState(ExceptionState::ConstructionContext, "property", "interface", scriptState()->context()->Global(), isolate());
|
| + ScriptState::Scope scope(getScriptState());
|
| + ExceptionState exceptionState(ExceptionState::ConstructionContext, "property", "interface", getScriptState()->context()->Global(), isolate());
|
| auto strategy = MockStrategy::create();
|
| Checkpoint checkpoint;
|
|
|
| @@ -512,14 +512,14 @@ TEST_F(ReadableStreamTest, BackpressureOnReading)
|
| stream->enqueue("world");
|
|
|
| checkpoint.Call(0);
|
| - stream->read(scriptState());
|
| + stream->read(getScriptState());
|
| checkpoint.Call(1);
|
| - stream->read(scriptState());
|
| + stream->read(getScriptState());
|
| checkpoint.Call(2);
|
| stream->enqueue("foo");
|
| stream->enqueue("bar");
|
| checkpoint.Call(3);
|
| - stream->read(scriptState());
|
| + stream->read(getScriptState());
|
| checkpoint.Call(4);
|
|
|
| stream->error(DOMException::create(AbortError, "done"));
|
| @@ -528,17 +528,17 @@ TEST_F(ReadableStreamTest, BackpressureOnReading)
|
| // Note: Detailed tests are on ReadableStreamReaderTest.
|
| TEST_F(ReadableStreamTest, ReadableStreamReader)
|
| {
|
| - ScriptState::Scope scope(scriptState());
|
| - ExceptionState exceptionState(ExceptionState::ConstructionContext, "property", "interface", scriptState()->context()->Global(), isolate());
|
| + ScriptState::Scope scope(getScriptState());
|
| + ExceptionState exceptionState(ExceptionState::ConstructionContext, "property", "interface", getScriptState()->context()->Global(), isolate());
|
| StringStream* stream = construct();
|
| - ReadableStreamReader* reader = stream->getReader(scriptState()->executionContext(), exceptionState);
|
| + ReadableStreamReader* reader = stream->getReader(getScriptState()->getExecutionContext(), exceptionState);
|
|
|
| ASSERT_TRUE(reader);
|
| EXPECT_FALSE(exceptionState.hadException());
|
| EXPECT_TRUE(reader->isActive());
|
| EXPECT_TRUE(stream->isLockedTo(reader));
|
|
|
| - ReadableStreamReader* another = stream->getReader(scriptState()->executionContext(), exceptionState);
|
| + ReadableStreamReader* another = stream->getReader(getScriptState()->getExecutionContext(), exceptionState);
|
| ASSERT_EQ(nullptr, another);
|
| EXPECT_TRUE(exceptionState.hadException());
|
| EXPECT_TRUE(reader->isActive());
|
| @@ -547,17 +547,17 @@ TEST_F(ReadableStreamTest, ReadableStreamReader)
|
|
|
| TEST_F(ReadableStreamTest, GetClosedReader)
|
| {
|
| - ScriptState::Scope scope(scriptState());
|
| - ExceptionState exceptionState(ExceptionState::ConstructionContext, "property", "interface", scriptState()->context()->Global(), isolate());
|
| + ScriptState::Scope scope(getScriptState());
|
| + ExceptionState exceptionState(ExceptionState::ConstructionContext, "property", "interface", getScriptState()->context()->Global(), isolate());
|
| StringStream* stream = construct();
|
| stream->close();
|
| - ReadableStreamReader* reader = stream->getReader(scriptState()->executionContext(), exceptionState);
|
| + ReadableStreamReader* reader = stream->getReader(getScriptState()->getExecutionContext(), exceptionState);
|
|
|
| ASSERT_TRUE(reader);
|
| EXPECT_FALSE(exceptionState.hadException());
|
|
|
| String onFulfilled, onRejected;
|
| - reader->closed(scriptState()).then(createCaptor(&onFulfilled), createCaptor(&onRejected));
|
| + reader->closed(getScriptState()).then(createCaptor(&onFulfilled), createCaptor(&onRejected));
|
|
|
| EXPECT_TRUE(reader->isActive());
|
| EXPECT_TRUE(onFulfilled.isNull());
|
| @@ -570,17 +570,17 @@ TEST_F(ReadableStreamTest, GetClosedReader)
|
|
|
| TEST_F(ReadableStreamTest, GetErroredReader)
|
| {
|
| - ScriptState::Scope scope(scriptState());
|
| - ExceptionState exceptionState(ExceptionState::ConstructionContext, "property", "interface", scriptState()->context()->Global(), isolate());
|
| + 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(scriptState()->executionContext(), exceptionState);
|
| + ReadableStreamReader* reader = stream->getReader(getScriptState()->getExecutionContext(), exceptionState);
|
|
|
| ASSERT_TRUE(reader);
|
| EXPECT_FALSE(exceptionState.hadException());
|
|
|
| String onFulfilled, onRejected;
|
| - reader->closed(scriptState()).then(createCaptor(&onFulfilled), createCaptor(&onRejected));
|
| + reader->closed(getScriptState()).then(createCaptor(&onFulfilled), createCaptor(&onRejected));
|
|
|
| EXPECT_TRUE(reader->isActive());
|
| EXPECT_TRUE(onFulfilled.isNull());
|
| @@ -593,8 +593,8 @@ TEST_F(ReadableStreamTest, GetErroredReader)
|
|
|
| TEST_F(ReadableStreamTest, StrictStrategy)
|
| {
|
| - ScriptState::Scope scope(scriptState());
|
| - ExceptionState exceptionState(ExceptionState::ConstructionContext, "property", "interface", scriptState()->context()->Global(), isolate());
|
| + ScriptState::Scope scope(getScriptState());
|
| + ExceptionState exceptionState(ExceptionState::ConstructionContext, "property", "interface", getScriptState()->context()->Global(), isolate());
|
| Checkpoint checkpoint;
|
| {
|
| InSequence s;
|
| @@ -613,23 +613,23 @@ TEST_F(ReadableStreamTest, StrictStrategy)
|
| EXPECT_CALL(*m_underlyingSource, pullSource());
|
| }
|
| StringStream* stream = new StringStream(m_underlyingSource, new StringStream::StrictStrategy);
|
| - ReadableStreamReader* reader = stream->getReader(scriptState()->executionContext(), exceptionState);
|
| + ReadableStreamReader* reader = stream->getReader(getScriptState()->getExecutionContext(), exceptionState);
|
|
|
| checkpoint.Call(0);
|
| stream->didSourceStart();
|
|
|
| checkpoint.Call(1);
|
| EXPECT_FALSE(stream->isPulling());
|
| - reader->read(scriptState());
|
| + reader->read(getScriptState());
|
| EXPECT_TRUE(stream->isPulling());
|
| checkpoint.Call(2);
|
| stream->enqueue("hello");
|
| EXPECT_FALSE(stream->isPulling());
|
| checkpoint.Call(3);
|
| - reader->read(scriptState());
|
| + reader->read(getScriptState());
|
| EXPECT_TRUE(stream->isPulling());
|
| checkpoint.Call(4);
|
| - reader->read(scriptState());
|
| + reader->read(getScriptState());
|
| EXPECT_TRUE(stream->isPulling());
|
| checkpoint.Call(5);
|
| stream->enqueue("hello");
|
| @@ -641,10 +641,10 @@ TEST_F(ReadableStreamTest, StrictStrategy)
|
| stream->enqueue("hello");
|
| EXPECT_FALSE(stream->isPulling());
|
| checkpoint.Call(8);
|
| - reader->read(scriptState());
|
| + reader->read(getScriptState());
|
| EXPECT_FALSE(stream->isPulling());
|
| checkpoint.Call(9);
|
| - reader->read(scriptState());
|
| + reader->read(getScriptState());
|
| EXPECT_TRUE(stream->isPulling());
|
|
|
| stream->error(DOMException::create(AbortError, "done"));
|
|
|