Index: Source/core/streams/ReadableStreamTest.cpp |
diff --git a/Source/core/streams/ReadableStreamTest.cpp b/Source/core/streams/ReadableStreamTest.cpp |
index 1d9c31f04f7f8259b401143654f6d1616bf2fc21..41b9719b5589cdf7e665e530b66aeeb5d0f3d114 100644 |
--- a/Source/core/streams/ReadableStreamTest.cpp |
+++ b/Source/core/streams/ReadableStreamTest.cpp |
@@ -210,8 +210,8 @@ TEST_F(ReadableStreamTest, WaitOnWaiting) |
EXPECT_TRUE(stream->isStarted()); |
EXPECT_TRUE(stream->isPulling()); |
- ScriptPromise p = stream->wait(scriptState()); |
- ScriptPromise q = stream->wait(scriptState()); |
+ ScriptPromise p = stream->ready(scriptState()); |
+ ScriptPromise q = stream->ready(scriptState()); |
EXPECT_EQ(ReadableStream::Waiting, stream->state()); |
EXPECT_EQ(q, p); |
@@ -235,7 +235,7 @@ TEST_F(ReadableStreamTest, WaitDuringStarting) |
EXPECT_CALL(checkpoint, Call(1)); |
} |
- stream->wait(scriptState()); |
+ stream->ready(scriptState()); |
checkpoint.Call(0); |
stream->didSourceStart(); |
checkpoint.Call(1); |
@@ -252,7 +252,7 @@ TEST_F(ReadableStreamTest, WaitAndError) |
StringStream* stream = construct(); |
String onFulfilled, onRejected; |
- ScriptPromise promise = stream->wait(scriptState()); |
+ ScriptPromise promise = stream->ready(scriptState()); |
promise.then(createCaptor(&onFulfilled), createCaptor(&onRejected)); |
EXPECT_EQ(ReadableStream::Waiting, stream->state()); |
EXPECT_TRUE(stream->isPulling()); |
@@ -264,7 +264,7 @@ TEST_F(ReadableStreamTest, WaitAndError) |
isolate()->RunMicrotasks(); |
EXPECT_TRUE(onFulfilled.isNull()); |
- EXPECT_EQ(promise, stream->wait(scriptState())); |
+ EXPECT_EQ(promise, stream->ready(scriptState())); |
EXPECT_EQ("NotFoundError: hello, error", onRejected); |
} |
@@ -302,7 +302,7 @@ TEST_F(ReadableStreamTest, EnqueueAndWait) |
EXPECT_TRUE(result); |
EXPECT_EQ(ReadableStream::Readable, stream->state()); |
- stream->wait(scriptState()).then(createCaptor(&onFulfilled), createCaptor(&onRejected)); |
+ stream->ready(scriptState()).then(createCaptor(&onFulfilled), createCaptor(&onRejected)); |
EXPECT_EQ(ReadableStream::Readable, stream->state()); |
EXPECT_FALSE(stream->isPulling()); |
EXPECT_TRUE(onFulfilled.isNull()); |
@@ -323,7 +323,7 @@ TEST_F(ReadableStreamTest, WaitAndEnqueue) |
String onFulfilled, onRejected; |
EXPECT_EQ(ReadableStream::Waiting, stream->state()); |
- stream->wait(scriptState()).then(createCaptor(&onFulfilled), createCaptor(&onRejected)); |
+ stream->ready(scriptState()).then(createCaptor(&onFulfilled), createCaptor(&onRejected)); |
isolate()->RunMicrotasks(); |
EXPECT_EQ(ReadableStream::Waiting, stream->state()); |
@@ -351,7 +351,7 @@ TEST_F(ReadableStreamTest, WaitAndEnqueueAndError) |
String onFulfilled, onRejected; |
EXPECT_EQ(ReadableStream::Waiting, stream->state()); |
- ScriptPromise promise = stream->wait(scriptState()); |
+ ScriptPromise promise = stream->ready(scriptState()); |
promise.then(createCaptor(&onFulfilled), createCaptor(&onRejected)); |
isolate()->RunMicrotasks(); |
@@ -374,7 +374,7 @@ TEST_F(ReadableStreamTest, WaitAndEnqueueAndError) |
stream->error(DOMException::create(NotFoundError, "error")); |
EXPECT_EQ(ReadableStream::Errored, stream->state()); |
- EXPECT_NE(promise, stream->wait(scriptState())); |
+ EXPECT_NE(promise, stream->ready(scriptState())); |
} |
TEST_F(ReadableStreamTest, CloseWhenWaiting) |
@@ -385,7 +385,7 @@ TEST_F(ReadableStreamTest, CloseWhenWaiting) |
StringStream* stream = construct(); |
EXPECT_EQ(ReadableStream::Waiting, stream->state()); |
- stream->wait(scriptState()).then(createCaptor(&onWaitFulfilled), createCaptor(&onWaitRejected)); |
+ stream->ready(scriptState()).then(createCaptor(&onWaitFulfilled), createCaptor(&onWaitRejected)); |
stream->closed(scriptState()).then(createCaptor(&onClosedFulfilled), createCaptor(&onClosedRejected)); |
isolate()->RunMicrotasks(); |
@@ -482,7 +482,7 @@ TEST_F(ReadableStreamTest, EnqueuedAndRead) |
} |
stream->enqueue("hello"); |
- ScriptPromise promise = stream->wait(scriptState()); |
+ ScriptPromise promise = stream->ready(scriptState()); |
EXPECT_EQ(ReadableStream::Readable, stream->state()); |
EXPECT_FALSE(stream->isPulling()); |
@@ -496,7 +496,7 @@ TEST_F(ReadableStreamTest, EnqueuedAndRead) |
EXPECT_TRUE(stream->isPulling()); |
EXPECT_FALSE(stream->isDraining()); |
- ScriptPromise newPromise = stream->wait(scriptState()); |
+ ScriptPromise newPromise = stream->ready(scriptState()); |
newPromise.then(createCaptor(&onFulfilled), createCaptor(&onRejected)); |
isolate()->RunMicrotasks(); |
EXPECT_NE(promise, newPromise); |
@@ -521,7 +521,7 @@ TEST_F(ReadableStreamTest, EnqueueTwiceAndRead) |
EXPECT_TRUE(stream->enqueue("hello")); |
EXPECT_TRUE(stream->enqueue("bye")); |
- ScriptPromise promise = stream->wait(scriptState()); |
+ ScriptPromise promise = stream->ready(scriptState()); |
EXPECT_EQ(ReadableStream::Readable, stream->state()); |
EXPECT_FALSE(stream->isPulling()); |
@@ -535,7 +535,7 @@ TEST_F(ReadableStreamTest, EnqueueTwiceAndRead) |
EXPECT_TRUE(stream->isPulling()); |
EXPECT_FALSE(stream->isDraining()); |
- ScriptPromise newPromise = stream->wait(scriptState()); |
+ ScriptPromise newPromise = stream->ready(scriptState()); |
EXPECT_EQ(promise, newPromise); |
stream->error(DOMException::create(AbortError, "done")); |
@@ -552,7 +552,7 @@ TEST_F(ReadableStreamTest, CloseWhenReadable) |
stream->close(); |
EXPECT_FALSE(stream->enqueue("should be ignored")); |
- ScriptPromise promise = stream->wait(scriptState()); |
+ ScriptPromise promise = stream->ready(scriptState()); |
EXPECT_EQ(ReadableStream::Readable, stream->state()); |
EXPECT_FALSE(stream->isPulling()); |
EXPECT_TRUE(stream->isDraining()); |
@@ -560,7 +560,7 @@ TEST_F(ReadableStreamTest, CloseWhenReadable) |
String chunk; |
EXPECT_TRUE(stream->read(scriptState(), m_exceptionState).toString(chunk)); |
EXPECT_EQ("hello", chunk); |
- EXPECT_EQ(promise, stream->wait(scriptState())); |
+ EXPECT_EQ(promise, stream->ready(scriptState())); |
isolate()->RunMicrotasks(); |
@@ -572,7 +572,7 @@ TEST_F(ReadableStreamTest, CloseWhenReadable) |
EXPECT_EQ("bye", chunk); |
EXPECT_FALSE(m_exceptionState.hadException()); |
- EXPECT_EQ(promise, stream->wait(scriptState())); |
+ EXPECT_EQ(promise, stream->ready(scriptState())); |
EXPECT_EQ(ReadableStream::Closed, stream->state()); |
EXPECT_FALSE(stream->isPulling()); |
@@ -637,12 +637,12 @@ TEST_F(ReadableStreamTest, CancelWhenWaiting) |
} |
EXPECT_EQ(ReadableStream::Waiting, stream->state()); |
- ScriptPromise wait = stream->wait(scriptState()); |
+ ScriptPromise ready = stream->ready(scriptState()); |
EXPECT_NE(promise, stream->cancel(scriptState(), reason)); |
EXPECT_EQ(ReadableStream::Closed, stream->state()); |
- EXPECT_EQ(stream->wait(scriptState()), wait); |
+ EXPECT_EQ(stream->ready(scriptState()), ready); |
- wait.then(createCaptor(&onFulfilled), createCaptor(&onRejected)); |
+ ready.then(createCaptor(&onFulfilled), createCaptor(&onRejected)); |
EXPECT_TRUE(onFulfilled.isNull()); |
EXPECT_TRUE(onRejected.isNull()); |
@@ -665,7 +665,7 @@ TEST_F(ReadableStreamTest, CancelWhenReadable) |
} |
stream->enqueue("hello"); |
- ScriptPromise wait = stream->wait(scriptState()); |
+ ScriptPromise ready = stream->ready(scriptState()); |
EXPECT_EQ(ReadableStream::Readable, stream->state()); |
ScriptPromise cancelResult = stream->cancel(scriptState(), reason); |
@@ -674,7 +674,7 @@ TEST_F(ReadableStreamTest, CancelWhenReadable) |
EXPECT_NE(promise, cancelResult); |
EXPECT_EQ(ReadableStream::Closed, stream->state()); |
- EXPECT_EQ(stream->wait(scriptState()), wait); |
+ EXPECT_EQ(stream->ready(scriptState()), ready); |
EXPECT_TRUE(onCancelFulfilled.isNull()); |
EXPECT_TRUE(onCancelRejected.isNull()); |